Versions in this module Expand all Collapse all v0 v0.2.0 Jul 27, 2016 v0.1.0 Jun 7, 2016 Changes in this version + const DefaultConnectTimeout + const DefaultSessionTimeout + var DefaultACL = zk.WorldACL(zk.PermAll) + var ErrClientClosed = errors.New("client service closed") + var ErrInvalidCredentials = errors.New("invalid credentials provided") + var ErrNodeNotFound = errors.New("node not found") + var ErrNotRegistered = errors.New("not registered") + type Client interface + CreateParentNodes func(path string) error + Deregister func(s *Service) error + GetEntries func(path string) ([]string, <-chan zk.Event, error) + Register func(s *Service) error + Stop func() + func NewClient(servers []string, logger log.Logger, options ...Option) (Client, error) + type Option func(*clientConfig) error + func ACL(acl []zk.ACL) Option + func ConnectTimeout(t time.Duration) Option + func Credentials(user, pass string) Option + func EventHandler(handler func(zk.Event)) Option + func Payload(payload [][]byte) Option + func SessionTimeout(t time.Duration) Option + type Registrar struct + func NewRegistrar(client Client, service Service, logger log.Logger) *Registrar + func (r *Registrar) Deregister() + func (r *Registrar) Register() + type Service struct + Data []byte + Name string + Path string + type Subscriber struct + func NewSubscriber(c Client, path string, factory sd.Factory, logger log.Logger) (*Subscriber, error) + func (s *Subscriber) Endpoints() ([]endpoint.Endpoint, error) + func (s *Subscriber) Stop()
Go to main page