zookeeper

Documentation

Index

• Constants
• func ZkIterate(conn *zk.Conn, root string, parent string, depth int, iterator ZkIterator) error
• type WatchBox
  • func (o *WatchBox) GetPath() string
  • func (o *WatchBox) GetType() WatchType
• type WatchRoutine
• type WatchType
• type ZkIterator
• type ZooDiscovery
  • func (o *ZooDiscovery) GatewayPublish(gatekey string, gateway qtiny.Gateway) error
  • func (o *ZooDiscovery) GetNanoZNodePath(address string) string
  • func (o *ZooDiscovery) GetNanoZNodeSelfPath(address string, gateway qtiny.Gateway) string
  • func (o *ZooDiscovery) Init(config map[string]interface{}) error
  • func (o *ZooDiscovery) NanoLocalRegister(nano *qtiny.Nano) error
  • func (o *ZooDiscovery) NanoRemoteGet(address string) (*qtiny.Nano, error)
  • func (o *ZooDiscovery) Start(config map[string]interface{}) error
  • func (o *ZooDiscovery) Stop(config map[string]interface{}) error
• type ZooGateway
  • func (o *ZooGateway) Broadcast(message *qtiny.Message, discovery qtiny.Discovery) error
  • func (o *ZooGateway) GetMeta() map[string]interface{}
  • func (o *ZooGateway) GetQueueZNodePath(nodeId string) string
  • func (o *ZooGateway) GetType() string
  • func (o *ZooGateway) Init(config map[string]interface{}) error
  • func (o *ZooGateway) Multicast(message *qtiny.Message, discovery qtiny.Discovery) error
  • func (o *ZooGateway) Post(message *qtiny.Message, discovery qtiny.Discovery) error
  • func (o *ZooGateway) Start(config map[string]interface{}) error
  • func (o *ZooGateway) Stop(config map[string]interface{}) error
• type ZooWatcher
  • func (o *ZooWatcher) AddCallback(callback ZooWatcherCallback)
  • func (o *ZooWatcher) Create(path string, data []byte, createflags int32, acl []zk.ACL, update bool) (bool, error)
  • func (o *ZooWatcher) Delete(path string, removeself, recursive bool) error
  • func (o *ZooWatcher) GetConn() *zk.Conn
  • func (o *ZooWatcher) IsConnected() bool
  • func (o *ZooWatcher) Start(config map[string]interface{}) error
  • func (o *ZooWatcher) Stop(map[string]interface{}) error
  • func (o *ZooWatcher) UnWatch(wtype WatchType, path string)
  • func (o *ZooWatcher) WaitForConnected() <-chan bool
  • func (o *ZooWatcher) Watch(wtype WatchType, path string, data interface{}, interval time.Duration, ...)
• type ZooWatcherCallback

Constants

const PathConnection = "/qportal"

const PathNano = "/qnano"

Functions

func ZkIterate

func ZkIterate(conn *zk.Conn, root string, parent string, depth int, iterator ZkIterator) error

Types

type WatchBox

type WatchBox struct {
	Path   string
	Logger *log.Logger
	Data   interface{}
	// contains filtered or unexported fields
}

func (*WatchBox) GetPath

func (o *WatchBox) GetPath() string

func (*WatchBox) GetType

func (o *WatchBox) GetType() WatchType

type WatchRoutine

type WatchRoutine func(event *zk.Event, stat *zk.Stat, data interface{}, box *WatchBox, watcher *ZooWatcher, err error) bool

type WatchType

type WatchType int

const (
	WatchTypeExist    WatchType = 1
	WatchTypeGet      WatchType = 2
	WatchTypeChildren WatchType = 3
)

type ZkIterator

type ZkIterator func(conn *zk.Conn, current string, parent string, root string, depth int) bool

type ZooDiscovery

type ZooDiscovery struct {
	memory.MemDiscovery
	// contains filtered or unexported fields
}

func (*ZooDiscovery) GatewayPublish

func (o *ZooDiscovery) GatewayPublish(gatekey string, gateway qtiny.Gateway) error

func (*ZooDiscovery) GetNanoZNodePath

func (o *ZooDiscovery) GetNanoZNodePath(address string) string

func (*ZooDiscovery) GetNanoZNodeSelfPath

func (o *ZooDiscovery) GetNanoZNodeSelfPath(address string, gateway qtiny.Gateway) string

func (*ZooDiscovery) Init

func (o *ZooDiscovery) Init(config map[string]interface{}) error

func (*ZooDiscovery) NanoLocalRegister

func (o *ZooDiscovery) NanoLocalRegister(nano *qtiny.Nano) error

func (*ZooDiscovery) NanoRemoteGet

func (o *ZooDiscovery) NanoRemoteGet(address string) (*qtiny.Nano, error)

func (*ZooDiscovery) Start

func (o *ZooDiscovery) Start(config map[string]interface{}) error

func (*ZooDiscovery) Stop

func (o *ZooDiscovery) Stop(config map[string]interface{}) error

type ZooGateway

type ZooGateway struct {
	memory.MemGateway
	// contains filtered or unexported fields
}

func (*ZooGateway) Broadcast

func (o *ZooGateway) Broadcast(message *qtiny.Message, discovery qtiny.Discovery) error

func (*ZooGateway) GetMeta

func (o *ZooGateway) GetMeta() map[string]interface{}

func (*ZooGateway) GetQueueZNodePath

func (o *ZooGateway) GetQueueZNodePath(nodeId string) string

func (*ZooGateway) GetType

func (o *ZooGateway) GetType() string

func (*ZooGateway) Init

func (o *ZooGateway) Init(config map[string]interface{}) error

func (*ZooGateway) Multicast

func (o *ZooGateway) Multicast(message *qtiny.Message, discovery qtiny.Discovery) error

func (*ZooGateway) Post

func (o *ZooGateway) Post(message *qtiny.Message, discovery qtiny.Discovery) error

func (*ZooGateway) Start

func (o *ZooGateway) Start(config map[string]interface{}) error

func (*ZooGateway) Stop

func (o *ZooGateway) Stop(config map[string]interface{}) error

type ZooWatcher

type ZooWatcher struct {
	Id                string
	Endpoints         []string
	SessionTimeout    time.Duration
	ReconnectInterval time.Duration

	Logger *log.Logger
	// contains filtered or unexported fields
}

func (*ZooWatcher) AddCallback

func (o *ZooWatcher) AddCallback(callback ZooWatcherCallback)

func (*ZooWatcher) Create

func (o *ZooWatcher) Create(path string, data []byte, createflags int32, acl []zk.ACL, update bool) (bool, error)

func (*ZooWatcher) Delete

func (o *ZooWatcher) Delete(path string, removeself, recursive bool) error

func (*ZooWatcher) GetConn

func (o *ZooWatcher) GetConn() *zk.Conn

func (*ZooWatcher) IsConnected

func (o *ZooWatcher) IsConnected() bool

func (*ZooWatcher) Start

func (o *ZooWatcher) Start(config map[string]interface{}) error

func (*ZooWatcher) Stop

func (o *ZooWatcher) Stop(map[string]interface{}) error

func (*ZooWatcher) UnWatch

func (o *ZooWatcher) UnWatch(wtype WatchType, path string)

func (*ZooWatcher) WaitForConnected

func (o *ZooWatcher) WaitForConnected() <-chan bool

func (*ZooWatcher) Watch

func (o *ZooWatcher) Watch(wtype WatchType, path string, data interface{}, interval time.Duration, routine WatchRoutine)

type ZooWatcherCallback

type ZooWatcherCallback func(event *zk.Event, watcher *ZooWatcher, err error)