Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DiscoveryV2 ¶
DiscoveryV2 discover bcs module, examples: bcs-api、bcs-scheduler、bcs-mesos-driver base on bkbcs zookeeper discovery mechanism
func (*DiscoveryV2) GetModuleServers ¶
func (r *DiscoveryV2) GetModuleServers(moduleName string) ([]interface{}, error)
GetModuleServers module: types.BCS_MODULE_SCHEDULER... list all servers if mesos-apiserver/k8s-apiserver module={module}/clusterid, for examples: mesosdriver/BCS-TESTBCSTEST01-10001
func (*DiscoveryV2) GetRandModuleServer ¶
func (r *DiscoveryV2) GetRandModuleServer(moduleName string) (interface{}, error)
GetRandModuleServer get random one server
func (*DiscoveryV2) RegisterEventFunc ¶
func (r *DiscoveryV2) RegisterEventFunc(handleFunc EventHandleFunc)
RegisterEventFunc register event handle function
type EventHandleFunc ¶
type EventHandleFunc func(module string)
EventHandleFunc module: types.BCS_MODULE_SCHEDULER... if mesos-apiserver/k8s-apiserver module={module}/clusterid, for examples: mesosdriver/BCS-TESTBCSTEST01-10001
type ModuleDiscovery ¶
type ModuleDiscovery interface {
// module: types.BCS_MODULE_SCHEDULER...
// list all servers
//if mesos-apiserver/k8s-apiserver module={module}/clusterid, for examples: mesosdriver/BCS-TESTBCSTEST01-10001
GetModuleServers(module string) ([]interface{}, error)
// get random one server
//if mesos-apiserver/k8s-apiserver module={module}/clusterid, for examples: mesosdriver/BCS-TESTBCSTEST01-10001
GetRandModuleServer(moduleName string) (interface{}, error)
// register event handle function
RegisterEventFunc(handleFunc EventHandleFunc)
// Stop close discovery
Stop()
}
ModuleDiscovery bkbcs module discovery interface difinition
func NewDiscoveryV2 ¶
func NewDiscoveryV2(zkserv string, modules []string) (ModuleDiscovery, error)
NewDiscoveryV2 create a object of DiscoveryV2