modulediscovery

package
v1.19.1 Latest Latest
Warning

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

Go to latest
Published: Oct 25, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DiscoveryV2

type DiscoveryV2 struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

func (*DiscoveryV2) Stop

func (r *DiscoveryV2) Stop()

Stop the DiscoveryV2

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

Jump to

Keyboard shortcuts

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