zookeeper

Documentation

Index

• type CacheListener
  • func NewCacheListener(rootPath string, listener *zookeeper.ZkEventListener) *CacheListener
  • func (l *CacheListener) AddListener(key string, listener mapping.MappingListener)
  • func (l *CacheListener) DataChange(event remoting.Event) bool
  • func (l *CacheListener) RemoveListener(key string, listener mapping.MappingListener)
• type ListenerSet
  • func NewListenerSet() *ListenerSet
  • func (s *ListenerSet) Add(listener mapping.MappingListener)
  • func (s *ListenerSet) ForEach(f func(mapping.MappingListener) error) error
  • func (s *ListenerSet) Has(listener mapping.MappingListener) bool
  • func (s *ListenerSet) Remove(listener mapping.MappingListener)

Types

type CacheListener

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

CacheListener defines keyListeners and rootPath

func NewCacheListener

func NewCacheListener(rootPath string, listener *zookeeper.ZkEventListener) *CacheListener

NewCacheListener creates a new CacheListener

func (*CacheListener) AddListener

func (l *CacheListener) AddListener(key string, listener mapping.MappingListener)

AddListener will add a listener if loaded

func (*CacheListener) DataChange

func (l *CacheListener) DataChange(event remoting.Event) bool

DataChange changes all listeners' event

func (*CacheListener) RemoveListener

func (l *CacheListener) RemoveListener(key string, listener mapping.MappingListener)

RemoveListener will delete a listener if loaded

type ListenerSet

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

ListenerSet defines a thread-safe set of listeners

func NewListenerSet

func NewListenerSet() *ListenerSet

func (*ListenerSet) Add

func (s *ListenerSet) Add(listener mapping.MappingListener)

Add adds a listener to the set

func (*ListenerSet) ForEach

func (s *ListenerSet) ForEach(f func(mapping.MappingListener) error) error

ForEach iterates over all listeners in the set

func (*ListenerSet) Has

func (s *ListenerSet) Has(listener mapping.MappingListener) bool

Has checks if a listener exists in the set

func (*ListenerSet) Remove

func (s *ListenerSet) Remove(listener mapping.MappingListener)

Remove removes a listener from the set