discoverer

Documentation

Index

• Variables
• func InitDiscoverer(key string, disConfig interface{}) error
• func InitDiscoverers() (err error)
• type Discoverer
  • func GetDiscoverer(key string) Discoverer
  • func GetDiscoverers() []Discoverer
  • func NewDiscovererMock(_ interface{}) (Discoverer, error)
  • func NewNacosDiscoverer(disConfig interface{}) (Discoverer, error)
  • func NewZookeeperDiscoverer(disConfig interface{}) (Discoverer, error)
• type MockInterface
  • func (m *MockInterface) Delete(msg *message.Message) error
  • func (m *MockInterface) Query(msg *message.Message) error
  • func (m *MockInterface) Stop()
  • func (m *MockInterface) Update(oldMsg, msg *message.Message) error
  • func (m *MockInterface) Watch() chan *message.Message
• type NacosDiscoverer
  • func (d *NacosDiscoverer) Delete(msg *message.Message) error
  • func (d *NacosDiscoverer) Query(msg *message.Message) error
  • func (d *NacosDiscoverer) Stop()
  • func (d *NacosDiscoverer) Update(oldMsg, msg *message.Message) error
  • func (d *NacosDiscoverer) Watch() chan *message.Message
• type NacosService
• type NewDiscoverFunc
• type ZookeeperDiscoverer
  • func (zd *ZookeeperDiscoverer) Delete(msg *message.Message) error
  • func (zd *ZookeeperDiscoverer) Query(msg *message.Message) error
  • func (zd *ZookeeperDiscoverer) Stop()
  • func (zd *ZookeeperDiscoverer) Update(oldMsg, msg *message.Message) error
  • func (zd *ZookeeperDiscoverer) Watch() chan *message.Message
• type ZookeeperService

Variables

var (
	Discoveries = make(map[string]NewDiscoverFunc)
)

Functions

func InitDiscoverer

func InitDiscoverer(key string, disConfig interface{}) error

func InitDiscoverers

func InitDiscoverers() (err error)

Types

type Discoverer

type Discoverer interface {
	Stop()
	Query(*message.Message) error
	Update(*message.Message, *message.Message) error
	Delete(*message.Message) error
	Watch() chan *message.Message
}

Discoverer defines the component that interact nacos, consul and so on

func GetDiscoverer

func GetDiscoverer(key string) Discoverer

func GetDiscoverers

func GetDiscoverers() []Discoverer

func NewDiscovererMock

func NewDiscovererMock(_ interface{}) (Discoverer, error)

func NewNacosDiscoverer

func NewNacosDiscoverer(disConfig interface{}) (Discoverer, error)

func NewZookeeperDiscoverer

func NewZookeeperDiscoverer(disConfig interface{}) (Discoverer, error)

NewZookeeperDiscoverer generate zookeeper discoverer instance

type MockInterface

type MockInterface struct {
	mock.Mock
}

func (*MockInterface) Delete

func (m *MockInterface) Delete(msg *message.Message) error

func (*MockInterface) Query

func (m *MockInterface) Query(msg *message.Message) error

func (*MockInterface) Stop

func (m *MockInterface) Stop()

func (*MockInterface) Update

func (m *MockInterface) Update(oldMsg, msg *message.Message) error

func (*MockInterface) Watch

func (m *MockInterface) Watch() chan *message.Message

type NacosDiscoverer

type NacosDiscoverer struct {

	// nacos server configs, grouping by authentication information
	ServerConfigs map[string][]constant.ServerConfig
	// contains filtered or unexported fields
}

func (*NacosDiscoverer) Delete

func (d *NacosDiscoverer) Delete(msg *message.Message) error

func (*NacosDiscoverer) Query

func (d *NacosDiscoverer) Query(msg *message.Message) error

func (*NacosDiscoverer) Stop

func (d *NacosDiscoverer) Stop()

func (*NacosDiscoverer) Update

func (d *NacosDiscoverer) Update(oldMsg, msg *message.Message) error

func (*NacosDiscoverer) Watch

func (d *NacosDiscoverer) Watch() chan *message.Message

type NacosService

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

type NewDiscoverFunc

type NewDiscoverFunc func(disConfig interface{}) (Discoverer, error)

type ZookeeperDiscoverer

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

func (*ZookeeperDiscoverer) Delete

func (zd *ZookeeperDiscoverer) Delete(msg *message.Message) error

func (*ZookeeperDiscoverer) Query

func (zd *ZookeeperDiscoverer) Query(msg *message.Message) error

func (*ZookeeperDiscoverer) Stop

func (zd *ZookeeperDiscoverer) Stop()

func (*ZookeeperDiscoverer) Update

func (zd *ZookeeperDiscoverer) Update(oldMsg, msg *message.Message) error

func (*ZookeeperDiscoverer) Watch

func (zd *ZookeeperDiscoverer) Watch() chan *message.Message

type ZookeeperService

type ZookeeperService struct {
	Name string

	BindEntities map[string]*message.Message
	WatchPath    string
	WatchContext context.Context
	WatchCancel  context.CancelFunc
	// contains filtered or unexported fields
}