zookeeper

Documentation

Index

• type Config
• type Registrar
  • func New(conf *Config, logger logrus.FieldLogger) (*Registrar, error)
  • func (r *Registrar) Close()
  • func (r *Registrar) Register(service *registry.Info) error
  • func (r *Registrar) Unregister(service *registry.Info) error

Types

type Config

type Config struct {
	ZkServers []string
	Directory string
	Timeout   time.Duration
}

type Registrar

type Registrar struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(conf *Config, logger logrus.FieldLogger) (*Registrar, error)

func (*Registrar) Close

func (r *Registrar) Close()

func (*Registrar) Register

func (r *Registrar) Register(service *registry.Info) error

func (*Registrar) Unregister

func (r *Registrar) Unregister(service *registry.Info) error