zookeeper

Documentation

Index

• func Watcher(conn *zk.Conn)
• type Ensemble
  • func ConnectEnsemble(address string) Ensemble
  • func (e *Ensemble) CreateEphemeralZnode(serviceCode string)
  • func (e *Ensemble) UpdateCacheServerMapping(replication bool)

Functions

func Watcher

func Watcher(conn *zk.Conn)

Types

type Ensemble

type Ensemble struct {
	// contains filtered or unexported fields
}

func ConnectEnsemble

func ConnectEnsemble(address string) Ensemble

func (*Ensemble) CreateEphemeralZnode

func (e *Ensemble) CreateEphemeralZnode(serviceCode string)

func (*Ensemble) UpdateCacheServerMapping

func (e *Ensemble) UpdateCacheServerMapping(replication bool)