Versions in this module Expand all Collapse all v0 v0.1.0 Jun 7, 2016 Changes in this version + type Client interface + GetEntries func(prefix string) ([]string, error) + WatchPrefix func(prefix string, responseChan chan *etcd.Response) + func NewClient(ctx context.Context, machines []string, options ClientOptions) (Client, error) + type ClientOptions struct + CaCert string + Cert string + DialKeepAline time.Duration + DialTimeout time.Duration + HeaderTimeoutPerRequest time.Duration + Key string + type Subscriber struct + func NewSubscriber(c Client, prefix string, factory sd.Factory, logger log.Logger) (*Subscriber, error) + func (s *Subscriber) Endpoints() ([]endpoint.Endpoint, error) + func (s *Subscriber) Stop()
Go to main page