registry

Documentation

Index

• type EventType
• type NodeEventType
• type Registry
• type ZookeeperRegistry
  • func NewZookeeperRegistry(servers []string) *ZookeeperRegistry
  • func (r *ZookeeperRegistry) Create(path string, ephemeral bool, data []byte) error
  • func (r *ZookeeperRegistry) Delete(path string) error
  • func (r *ZookeeperRegistry) GetData(path string) []byte
  • func (r *ZookeeperRegistry) On(path string, listener func(data []byte, eventType NodeEventType, err error))
  • func (r *ZookeeperRegistry) OnChange(listener func(eventType EventType))
  • func (r *ZookeeperRegistry) SetData(path string, data []byte) error

Types

type EventType

type EventType int32

const (
	Connecting EventType = 1
	Connected  EventType = 2
)

type NodeEventType

type NodeEventType int32

const (
	Create         NodeEventType = 1
	Delete         NodeEventType = 2
	DataChange     NodeEventType = 3
	ChildrenChange NodeEventType = 4
	NodeDelete     NodeEventType = 5
)

type Registry

type Registry interface {
	Create(path string, ephemeral bool, data []byte) error
	Delete(path string) error

	SetData(path string, data []byte) error
	GetData(path string) []byte

	On(path string, listener func(data []byte, eventType NodeEventType, err error))
	OnChange(listener func(listener EventType))
}

type ZookeeperRegistry

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

func NewZookeeperRegistry

func NewZookeeperRegistry(servers []string) *ZookeeperRegistry

func (*ZookeeperRegistry) Create

func (r *ZookeeperRegistry) Create(path string, ephemeral bool, data []byte) error

func (*ZookeeperRegistry) Delete

func (r *ZookeeperRegistry) Delete(path string) error

func (*ZookeeperRegistry) GetData

func (r *ZookeeperRegistry) GetData(path string) []byte

func (*ZookeeperRegistry) On

func (r *ZookeeperRegistry) On(path string, listener func(data []byte, eventType NodeEventType, err error))

func (*ZookeeperRegistry) OnChange

func (r *ZookeeperRegistry) OnChange(listener func(eventType EventType))

func (*ZookeeperRegistry) SetData

func (r *ZookeeperRegistry) SetData(path string, data []byte) error