zookeeper

Documentation

Index

• Constants
• type Option
• type Options
• type RegistryConfigurationListener
  • func NewRegistryConfigurationListener(client *zk.ZookeeperClient, reg *zkRegistry) *RegistryConfigurationListener
  • func (l *RegistryConfigurationListener) Close()
  • func (l *RegistryConfigurationListener) Next() (*registry.ServiceEvent, error)
  • func (l *RegistryConfigurationListener) Process(configType *config_center.ConfigChangeEvent)
• type RegistryDataListener
  • func NewRegistryDataListener(listener config_center.ConfigurationListener) *RegistryDataListener
  • func (l *RegistryDataListener) AddInterestedURL(url *common.URL)
  • func (l *RegistryDataListener) DataChange(eventType remoting.Event) bool

Constants

const (
	RegistryZkClient  = "zk registry"
	RegistryConnDelay = 3
)

Types

type Option

type Option func(*Options)

type Options

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

type RegistryConfigurationListener

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

func NewRegistryConfigurationListener

func NewRegistryConfigurationListener(client *zk.ZookeeperClient, reg *zkRegistry) *RegistryConfigurationListener

func (*RegistryConfigurationListener) Close

func (l *RegistryConfigurationListener) Close()

func (*RegistryConfigurationListener) Next

func (l *RegistryConfigurationListener) Next() (*registry.ServiceEvent, error)

func (*RegistryConfigurationListener) Process

func (l *RegistryConfigurationListener) Process(configType *config_center.ConfigChangeEvent)

type RegistryDataListener

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

func NewRegistryDataListener

func NewRegistryDataListener(listener config_center.ConfigurationListener) *RegistryDataListener

func (*RegistryDataListener) AddInterestedURL

func (l *RegistryDataListener) AddInterestedURL(url *common.URL)

func (*RegistryDataListener) DataChange

func (l *RegistryDataListener) DataChange(eventType remoting.Event) bool