Versions in this module Expand all Collapse all v0 v0.2.0 Jul 27, 2016 Changes in this version + var ErrNoKey = errors.New("no key provided") + var ErrNoValue = errors.New("no value provided") type Client + Deregister func(s Service) error + Register func(s Service) error type ClientOptions + CACert string + DialKeepAlive time.Duration + type Registrar struct + func NewRegistrar(client Client, service Service, logger log.Logger) *Registrar + func (r *Registrar) Deregister() + func (r *Registrar) Register() + type Service struct + DeleteOptions *etcd.DeleteOptions + Key string + Value string 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