discoverer

package
v0.0.0-...-bd8fb77 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL