package client
import "github.com/coreos/etcd/client"
Index ¶
- Variables
- type KeysAPI
- func NewDiscoveryKeysAPI(tr *http.Transport, eps []string, to time.Duration) (KeysAPI, error)
- func NewKeysAPI(tr *http.Transport, eps []string, to time.Duration) (KeysAPI, error)
- type MembersAPI
- type Node
- type Nodes
- type Response
- type Watcher
Variables ¶
var ( ErrTimeout = context.DeadlineExceeded DefaultRequestTimeout = 5 * time.Second )
var ( errors.New("client: no available etcd endpoints") ErrNoLeader = errors.New("client: no leader") ErrKeyNoExist = errors.New("client: key does not exist") ErrKeyExists = errors.New("client: key already exists") )=
var (
DefaultV2KeysPrefix = "/v2/keys"
)
var (
DefaultV2MembersPrefix = "/v2/members"
)
Types ¶
type KeysAPI ¶
type KeysAPI interface { Create(key, value string, ttl time.Duration) (*Response, error) Get(key string) (*Response, error) Watch(key string, idx uint64) Watcher RecursiveWatch(key string, idx uint64) Watcher }
func NewDiscoveryKeysAPI ¶
func NewKeysAPI ¶
type MembersAPI ¶
type MembersAPI interface { List() ([]httptypes.Member, error) Add(peerURL string) (*httptypes.Member, error) Remove(mID string) error }
func NewMembersAPI ¶
type Node ¶
type Node struct { Key string `json:"key"` Value string `json:"value"` Nodes Nodes `json:"nodes"` ModifiedIndex uint64 `json:"modifiedIndex"` CreatedIndex uint64 `json:"createdIndex"` }
func (*Node) String ¶
type Nodes ¶
type Nodes []*Node
type Response ¶
type Response struct { Action string `json:"action"` Node *Node `json:"node"` PrevNode *Node `json:"prevNode"` }
type Watcher ¶
Source Files ¶
cluster.go http.go keys.go members.go
- Version
- v0.5.0-alpha.1
- Published
- Oct 31, 2014
- Platform
- linux/amd64
- Imports
- 14 packages
- Last checked
- 26 minutes ago –
Tools for package owners.