Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

etcd

package

Go to main page

Versions in this module

v1

v1.1.1

Dec 16, 2014

v1.1.1-azure

Dec 23, 2014

v1.1.0

Dec 10, 2014

v1.0.2

Nov 25, 2014

v1.0.1

Nov 13, 2014

v1.0.0

Nov 11, 2014

v0

v0.15.1

Nov 4, 2014

v0.15.0

Oct 28, 2014

v0.14.1

Oct 23, 2014

v0.14.0

Oct 22, 2014

v0.13.1

Oct 16, 2014

v0.13.0

Oct 9, 2014

v0.12.0

Sep 23, 2014

v0.11.0

Aug 22, 2014

v0.10.0

Jul 24, 2014

Changes in this version

+ const ErrCodeEtcdNotReachable

+ const STRONG_CONSISTENCY

+ const WEAK_CONSISTENCY

+ var ErrRequestCancelled = errors.New("sending request is cancelled")

+ var ErrWatchStoppedByUser = errors.New("Watch stopped by the user via stop channel")

+ var VALID_DELETE_OPTIONS = validOptions

+ var VALID_GET_OPTIONS = validOptions

+ var VALID_POST_OPTIONS = validOptions

+ var VALID_PUT_OPTIONS = validOptions

+ func DefaultCheckRetry(cluster *Cluster, numReqs int, lastResp http.Response, err error) error

+ func GetLogger() *log.Logger

+ func SetLogger(l *log.Logger)

+ type Client struct

+ CheckRetry func(cluster *Cluster, numReqs int, lastResp http.Response, err error) error

+ func NewClient(machines []string) *Client

+ func NewClientFromFile(fpath string) (*Client, error)

+ func NewClientFromReader(reader io.Reader) (*Client, error)

+ func NewTLSClient(machines []string, cert, key, caCert string) (*Client, error)

+ func (c *Client) AddChild(key string, value string, ttl uint64) (*Response, error)

+ func (c *Client) AddChildDir(key string, ttl uint64) (*Response, error)

+ func (c *Client) AddRootCA(caCert string) error

+ func (c *Client) CloseCURL()

+ func (c *Client) CompareAndDelete(key string, prevValue string, prevIndex uint64) (*Response, error)

+ func (c *Client) CompareAndSwap(key string, value string, ttl uint64, prevValue string, prevIndex uint64) (*Response, error)

+ func (c *Client) Create(key string, value string, ttl uint64) (*Response, error)

+ func (c *Client) CreateDir(key string, ttl uint64) (*Response, error)

+ func (c *Client) CreateInOrder(dir string, value string, ttl uint64) (*Response, error)

+ func (c *Client) Delete(key string, recursive bool) (*Response, error)

+ func (c *Client) DeleteDir(key string) (*Response, error)

+ func (c *Client) Get(key string, sort, recursive bool) (*Response, error)

+ func (c *Client) GetCluster() []string

+ func (c *Client) MarshalJSON() ([]byte, error)

+ func (c *Client) OpenCURL()

+ func (c *Client) RawCompareAndDelete(key string, prevValue string, prevIndex uint64) (*RawResponse, error)

+ func (c *Client) RawCompareAndSwap(key string, value string, ttl uint64, prevValue string, prevIndex uint64) (*RawResponse, error)

+ func (c *Client) RawCreate(key string, value string, ttl uint64) (*RawResponse, error)

+ func (c *Client) RawCreateDir(key string, ttl uint64) (*RawResponse, error)

+ func (c *Client) RawCreateInOrder(dir string, value string, ttl uint64) (*RawResponse, error)

+ func (c *Client) RawDelete(key string, recursive bool, dir bool) (*RawResponse, error)

+ func (c *Client) RawGet(key string, sort, recursive bool) (*RawResponse, error)

+ func (c *Client) RawSet(key string, value string, ttl uint64) (*RawResponse, error)

+ func (c *Client) RawSetDir(key string, ttl uint64) (*RawResponse, error)

+ func (c *Client) RawUpdate(key string, value string, ttl uint64) (*RawResponse, error)

+ func (c *Client) RawUpdateDir(key string, ttl uint64) (*RawResponse, error)

+ func (c *Client) RawWatch(prefix string, waitIndex uint64, recursive bool, receiver chan *RawResponse, ...) (*RawResponse, error)

+ func (c *Client) RecvCURL() string

+ func (c *Client) SendRequest(rr *RawRequest) (*RawResponse, error)

+ func (c *Client) Set(key string, value string, ttl uint64) (*Response, error)

+ func (c *Client) SetCluster(machines []string) bool

+ func (c *Client) SetConsistency(consistency string) error

+ func (c *Client) SetDir(key string, ttl uint64) (*Response, error)

+ func (c *Client) SetPersistence(writer io.Writer)

+ func (c *Client) SetTransport(tr *http.Transport)

+ func (c *Client) SyncCluster() bool

+ func (c *Client) UnmarshalJSON(b []byte) error

+ func (c *Client) Update(key string, value string, ttl uint64) (*Response, error)

+ func (c *Client) UpdateDir(key string, ttl uint64) (*Response, error)

+ func (c *Client) Watch(prefix string, waitIndex uint64, recursive bool, receiver chan *Response, ...) (*Response, error)

+ type Cluster struct

+ Leader string

+ Machines []string

+ func NewCluster(machines []string) *Cluster

+ type Config struct

+ CaCertFile []string

+ CertFile string

+ Consistency string

+ DialTimeout time.Duration

+ KeyFile string

+ type EtcdError struct

+ Cause string

+ ErrorCode int

+ Index uint64

+ Message string

+ func (e EtcdError) Error() string

+ type Node struct

+ CreatedIndex uint64

+ Dir bool

+ Expiration *time.Time

+ Key string

+ ModifiedIndex uint64

+ Nodes Nodes

+ TTL int64

+ Value string

+ type Nodes []*Node

+ func (ns Nodes) Len() int

+ func (ns Nodes) Less(i, j int) bool

+ func (ns Nodes) Swap(i, j int)

+ type Options map[string]interface

+ type RawRequest struct

+ Cancel <-chan bool

+ Method string

+ RelativePath string

+ Values url.Values

+ func NewRawRequest(method, relativePath string, values url.Values, cancel <-chan bool) *RawRequest

+ type RawResponse struct

+ Body []byte

+ Header http.Header

+ StatusCode int

+ func (rr *RawResponse) Unmarshal() (*Response, error)

+ type Response struct

+ Action string

+ EtcdIndex uint64

+ Node *Node

+ PrevNode *Node

+ RaftIndex uint64

+ RaftTerm uint64