etcd

Documentation

Index

• Constants
• func IsKeyNotFound(err error) bool
• func IsNodeExist(err error) bool
• func NewClient(endpoints []string, transport *http.Transport, actionTimeout time.Duration) (*client, error)
• type Action
• type Client
• type Create
  • func (c *Create) HTTPRequest() (*http.Request, error)
  • func (c *Create) String() string
• type Delete
  • func (del *Delete) HTTPRequest() (*http.Request, error)
  • func (del *Delete) String() string
• type Error
  • func (e Error) Error() string
• type Get
  • func (g *Get) HTTPRequest() (*http.Request, error)
  • func (g *Get) String() string
• type LeaseManager
  • func NewLeaseManager(client Client, keyPrefix string) *LeaseManager
  • func (r *LeaseManager) AcquireLease(name string, machID string, ver int, period time.Duration) (lease.Lease, error)
  • func (r *LeaseManager) GetLease(name string) (lease.Lease, error)
  • func (r *LeaseManager) StealLease(name, machID string, ver int, period time.Duration, idx uint64) (lease.Lease, error)
• type Node
  • func (n *Node) String() string
  • func (n Node) TTLDuration() time.Duration
• type Nodes
• type Result
  • func (r *Result) String() string
• type Set
  • func (s *Set) HTTPRequest() (*http.Request, error)
  • func (s *Set) String() string
• type Update
  • func (u *Update) HTTPRequest() (*http.Request, error)
  • func (u *Update) String() string
• type Watch
  • func (w *Watch) HTTPRequest() (*http.Request, error)
  • func (w *Watch) String() string

Constants

const (
	ErrorKeyNotFound       = 100
	ErrorNodeExist         = 105
	ErrorEventIndexCleared = 401
)

Functions

func IsKeyNotFound

func IsKeyNotFound(err error) bool

func IsNodeExist

func IsNodeExist(err error) bool

func NewClient

func NewClient(endpoints []string, transport *http.Transport, actionTimeout time.Duration) (*client, error)

Types

type Action

type Action interface {
	fmt.Stringer
	HTTPRequest() (*http.Request, error)
}

type Client

type Client interface {
	Do(Action) (*Result, error)
	Wait(Action, <-chan struct{}) (*Result, error)
}

type Create

type Create struct {
	Key   string
	Value string
	TTL   time.Duration
}

func (*Create) HTTPRequest

func (c *Create) HTTPRequest() (*http.Request, error)

func (*Create) String

func (c *Create) String() string

type Delete

type Delete struct {
	Key           string
	Recursive     bool
	PreviousValue string
	PreviousIndex uint64
}

TODO(bcwaldon): Should Delete be separate from CompareAndDelete?

func (*Delete) HTTPRequest

func (del *Delete) HTTPRequest() (*http.Request, error)

func (*Delete) String

func (del *Delete) String() string

type Error

type Error struct {
	ErrorCode int    `json:"errorCode"`
	Message   string `json:"message"`
	Cause     string `json:"cause"`
	Index     uint64 `json:"index"`
}

func (Error) Error

func (e Error) Error() string

type Get

type Get struct {
	Key       string
	Sorted    bool
	Recursive bool
}

func (*Get) HTTPRequest

func (g *Get) HTTPRequest() (*http.Request, error)

func (*Get) String

func (g *Get) String() string

type LeaseManager

type LeaseManager struct {
	// contains filtered or unexported fields
}

func NewLeaseManager

func NewLeaseManager(client Client, keyPrefix string) *LeaseManager

func (*LeaseManager) AcquireLease

func (r *LeaseManager) AcquireLease(name string, machID string, ver int, period time.Duration) (lease.Lease, error)

func (*LeaseManager) GetLease

func (r *LeaseManager) GetLease(name string) (lease.Lease, error)

func (*LeaseManager) StealLease

func (r *LeaseManager) StealLease(name, machID string, ver int, period time.Duration, idx uint64) (lease.Lease, error)

type Node

type Node struct {
	Key           string `json:"key"`
	Value         string `json:"value"`
	TTL           int    `json:"ttl"`
	Nodes         Nodes  `json:"nodes"`
	ModifiedIndex uint64 `json:"modifiedIndex"`
	CreatedIndex  uint64 `json:"createdIndex"`
}

func (*Node) String

func (n *Node) String() string

func (Node) TTLDuration

func (n Node) TTLDuration() time.Duration

type Nodes

type Nodes []Node

type Result

type Result struct {
	Action   string `json:"action"`
	Node     *Node  `json:"node"`
	PrevNode *Node  `json:"prevNode"`
	Raw      []byte `json:"-"`
}

func (*Result) String

func (r *Result) String() string

type Set

type Set struct {
	Key           string
	Value         string
	TTL           time.Duration
	PreviousIndex uint64
	PreviousValue string
}

func (*Set) HTTPRequest

func (s *Set) HTTPRequest() (*http.Request, error)

func (*Set) String

func (s *Set) String() string

type Update

type Update struct {
	Key   string
	Value string
	TTL   time.Duration
}

func (*Update) HTTPRequest

func (u *Update) HTTPRequest() (*http.Request, error)

func (*Update) String

func (u *Update) String() string

type Watch

type Watch struct {
	Key       string
	Recursive bool
	WaitIndex uint64
}

func (*Watch) HTTPRequest

func (w *Watch) HTTPRequest() (*http.Request, error)

func (*Watch) String

func (w *Watch) String() string