discovery

Documentation

Index

• type DiscoveryInterface
  • func NewMockDiscoveryInterface() DiscoveryInterface
  • func NewServiceDiscovery(client *zk.ZkClient) (DiscoveryInterface, error)
• type Interface
• type MockDiscovery
  • func (d *MockDiscovery) ApiServer() Interface
  • func (d *MockDiscovery) AuditCtrl() Interface
  • func (d *MockDiscovery) AuthServer() Interface
  • func (d *MockDiscovery) CloudServer() Interface
  • func (d *MockDiscovery) CoreService() Interface
  • func (d *MockDiscovery) DataCollect() Interface
  • func (d *MockDiscovery) EventServer() Interface
  • func (d *MockDiscovery) GseProcServer() Interface
  • func (d *MockDiscovery) HostCtrl() Interface
  • func (d *MockDiscovery) HostServer() Interface
  • func (d *MockDiscovery) IsMaster() bool
  • func (d *MockDiscovery) MigrateServer() Interface
  • func (d *MockDiscovery) ObjectCtrl() Interface
  • func (d *MockDiscovery) OperationServer() Interface
  • func (d *MockDiscovery) ProcCtrl() Interface
  • func (d *MockDiscovery) ProcServer() Interface
  • func (d *MockDiscovery) TaskServer() Interface
  • func (d *MockDiscovery) TopoServer() Interface
• type ServiceManageInterface

Types

type DiscoveryInterface

type DiscoveryInterface interface {
	ApiServer() Interface
	MigrateServer() Interface
	EventServer() Interface
	HostServer() Interface
	ProcServer() Interface
	TopoServer() Interface
	DataCollect() Interface
	GseProcServer() Interface
	CoreService() Interface
	OperationServer() Interface
	TaskServer() Interface
	CloudServer() Interface
	AuthServer() Interface
	ServiceManageInterface
}

func NewMockDiscoveryInterface

func NewMockDiscoveryInterface() DiscoveryInterface

func NewServiceDiscovery

func NewServiceDiscovery(client *zk.ZkClient) (DiscoveryInterface, error)

NewServiceDiscovery new a simple discovery module which can be used to get alive server address

type Interface

type Interface interface {
	// 获取注册在zk上的所有服务节点
	GetServers() ([]string, error)
	// 最新的服务节点信息存放在该channel里，可被用来消费，以监听服务节点的变化
	GetServersChan() chan []string
}

type MockDiscovery

type MockDiscovery struct{}

func (*MockDiscovery) ApiServer

func (d *MockDiscovery) ApiServer() Interface

func (*MockDiscovery) AuditCtrl

func (d *MockDiscovery) AuditCtrl() Interface

func (*MockDiscovery) AuthServer

func (d *MockDiscovery) AuthServer() Interface

func (*MockDiscovery) CloudServer

func (d *MockDiscovery) CloudServer() Interface

func (*MockDiscovery) CoreService

func (d *MockDiscovery) CoreService() Interface

func (*MockDiscovery) DataCollect

func (d *MockDiscovery) DataCollect() Interface

func (*MockDiscovery) EventServer

func (d *MockDiscovery) EventServer() Interface

func (*MockDiscovery) GseProcServer

func (d *MockDiscovery) GseProcServer() Interface

func (*MockDiscovery) HostCtrl

func (d *MockDiscovery) HostCtrl() Interface

func (*MockDiscovery) HostServer

func (d *MockDiscovery) HostServer() Interface

func (*MockDiscovery) IsMaster

func (d *MockDiscovery) IsMaster() bool

func (*MockDiscovery) MigrateServer

func (d *MockDiscovery) MigrateServer() Interface

func (*MockDiscovery) ObjectCtrl

func (d *MockDiscovery) ObjectCtrl() Interface

func (*MockDiscovery) OperationServer

func (d *MockDiscovery) OperationServer() Interface

func (*MockDiscovery) ProcCtrl

func (d *MockDiscovery) ProcCtrl() Interface

func (*MockDiscovery) ProcServer

func (d *MockDiscovery) ProcServer() Interface

func (*MockDiscovery) TaskServer

func (d *MockDiscovery) TaskServer() Interface

func (*MockDiscovery) TopoServer

func (d *MockDiscovery) TopoServer() Interface

type ServiceManageInterface

type ServiceManageInterface interface {
	// 判断当前进程是否为master 进程， 服务注册节点的第一个节点
	IsMaster() bool
}