zookeeper

Documentation

Index

• Constants
• Variables
• func NewConsumerZookeeperRegistry(opts ...registry.Option) registry.Registry
• func NewProviderZookeeperRegistry(opts ...registry.Option) registry.Registry
• type DubboType
  • func (t DubboType) Role() string
  • func (t DubboType) String() string

Constants

const (
	ConsumerRegistryZkClient string = "consumer zk registry"
	WatcherZkClient          string = "watcher zk registry"
)

const (
	CONSUMER = iota
	CONFIGURATOR
	ROUTER
	PROVIDER
)

const (
	MAX_TIMES                   = 15 // 设置(wathcer)watchDir()等待时长
	Wactch_Event_Channel_Size   = 32 // 用于设置通知selector的event channel的size
	ZKCLIENT_EVENT_CHANNEL_SIZE = 4  // 设置用于zk client与watcher&consumer&provider之间沟通的channel的size
)

const (
	DEFAULT_REGISTRY_TIMEOUT = 1
)

const (
	ProviderRegistryZkClient string = "consumer zk registry"
)

Variables

var (
	DubboNodes       = [...]string{"consumers", "configurators", "routers", "providers"}
	DubboRole        = [...]string{"consumer", "", "", "provider"}
	RegistryZkClient = "zk registry"
)

var (
	ZK_CLIENT_CONN_NIL_ERR = errors.New("zookeeperclient{conn} is nil")
)

Functions

func NewConsumerZookeeperRegistry

func NewConsumerZookeeperRegistry(opts ...registry.Option) registry.Registry

func NewProviderZookeeperRegistry

func NewProviderZookeeperRegistry(opts ...registry.Option) registry.Registry

Types

type DubboType

type DubboType int

func (DubboType) Role

func (t DubboType) Role() string

func (DubboType) String

func (t DubboType) String() string