discover

package
v0.0.0-...-79e39e7 Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetServerById 

func GetServerById(serverId string) *treaty.Server

func GetServerByType 

func GetServerByType(serverType, serverArg string) *treaty.Server

func GetServerList 

func GetServerList() map[string]*treaty.Server

func GetServerTypeList 

func GetServerTypeList(serverType string) map[string]*treaty.Server

func InitDiscoverer 

func InitDiscoverer(cfg config.DiscoverConf)

func RegEventHandlers 

func RegEventHandlers(handlers ...EventHandler)

func Register 

func Register(server *treaty.Server) error

func UnRegister 

func UnRegister(server *treaty.Server) error

Types

type Discoverer 

type Discoverer interface {
	Register(server *treaty.Server) error                        //注册服务器
	UnRegister(server *treaty.Server) error                      //注册服务器
	GetServerList() map[string]*treaty.Server                    //获取所有服务信息
	GetServerById(serverId string) *treaty.Server                //根据serverId获取server信息
	GetServerByType(serverType, serverArg string) *treaty.Server //根据serverType及参数分配唯一server信息
	GetServerTypeList(serverType string) map[string]*treaty.Server
	RegEventHandlers(handlers ...EventHandler)
	EventHandlerExec(ev *clientv3.Event, server *treaty.Server)
}

Discoverer find service role

type EtcdDiscoverer 

type EtcdDiscoverer struct {
	Config           clientv3.Config
	Client           *clientv3.Client
	ServerList       map[string]*treaty.Server  //serverId=>server
	ServerTypeMap    map[string]*ServerTypeItem //serverType=>serverTypeItem
	ServerLock       *sync.RWMutex
	EventHandlerList []EventHandler
	Prefix           string
}

EtcdDiscoverer etcd discoverer

func NewEtcdDiscoverer 

func NewEtcdDiscoverer(opts ...EtcdOption) *EtcdDiscoverer

NewEtcdDiscoverer init EtcdDiscoverer

func (*EtcdDiscoverer) DumpServers 

func (e *EtcdDiscoverer) DumpServers()

func (*EtcdDiscoverer) EventHandlerExec 

func (e *EtcdDiscoverer) EventHandlerExec(ev *clientv3.Event, server *treaty.Server)

func (*EtcdDiscoverer) FindServer 

func (e *EtcdDiscoverer) FindServer(serverType string) []*treaty.Server

func (*EtcdDiscoverer) FindServerList 

func (e *EtcdDiscoverer) FindServerList() map[string][]*treaty.Server

func (*EtcdDiscoverer) GetServerById 

func (e *EtcdDiscoverer) GetServerById(serverId string) *treaty.Server

func (*EtcdDiscoverer) GetServerByType 

func (e *EtcdDiscoverer) GetServerByType(serverType, serverArg string) *treaty.Server

func (*EtcdDiscoverer) GetServerList 

func (e *EtcdDiscoverer) GetServerList() map[string]*treaty.Server

func (*EtcdDiscoverer) GetServerTypeList 

func (e *EtcdDiscoverer) GetServerTypeList(serverType string) map[string]*treaty.Server

func (*EtcdDiscoverer) Init 

func (e *EtcdDiscoverer) Init()

Init init

func (*EtcdDiscoverer) IsCurEvent 

func (e *EtcdDiscoverer) IsCurEvent(key string) bool

func (*EtcdDiscoverer) RegEventHandlers 

func (e *EtcdDiscoverer) RegEventHandlers(handlers ...EventHandler)

func (*EtcdDiscoverer) Register 

func (e *EtcdDiscoverer) Register(server *treaty.Server) error

Register register

func (*EtcdDiscoverer) UnRegister 

func (e *EtcdDiscoverer) UnRegister(server *treaty.Server) error

func (*EtcdDiscoverer) Watcher 

func (e *EtcdDiscoverer) Watcher()

type EtcdOption 

type EtcdOption func(e *EtcdDiscoverer)

func WithEtcdDialTimeOut 

func WithEtcdDialTimeOut(d time.Duration) EtcdOption

func WithEtcdEndpoints 

func WithEtcdEndpoints(endpoints []string) EtcdOption

func WithEtcdPrefix 

func WithEtcdPrefix(prefix string) EtcdOption

type EventHandler 

type EventHandler func(ev *clientv3.Event, server *treaty.Server)

type Finder 

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

func NewFinder 

func NewFinder() *Finder

func (*Finder) GetServerCache 

func (f *Finder) GetServerCache(serverType string, userId int) *treaty.Server

func (*Finder) GetServerCache2 

func (f *Finder) GetServerCache2(serverType string, arg string) *treaty.Server

func (*Finder) GetServerDiscover 

func (f *Finder) GetServerDiscover(serverType string, userId int) *treaty.Server

func (*Finder) GetServerDiscover2 

func (f *Finder) GetServerDiscover2(serverType string, arg string) *treaty.Server

func (*Finder) GetUserServer 

func (f *Finder) GetUserServer(serverType string, userId int) *treaty.Server

func (*Finder) GetUserServer2 

func (f *Finder) GetUserServer2(serverType string, arg string) *treaty.Server

func (*Finder) RemoveUserCache 

func (f *Finder) RemoveUserCache(userId int)

func (*Finder) RemoveUserCache2 

func (f *Finder) RemoveUserCache2(arg string)

func (*Finder) ServerEventHandler 

func (f *Finder) ServerEventHandler(ev *clientv3.Event, server *treaty.Server)

type ServerTypeItem 

type ServerTypeItem struct {
	List map[string]*treaty.Server
	// contains filtered or unexported fields
}

func NewServerTypeItem 

func NewServerTypeItem() *ServerTypeItem

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.