Documentation
¶
Index ¶
- Constants
- func RegisterSDManagerInitializers(name string, initFunc InitFunc)
- type DummyServiceDiscoveryManager
- type InitFunc
- type ServiceDiscoveryManager
- func GetSDManager(ctx context.Context, agentCtx *katalystbase.GenericContext, ...) (ServiceDiscoveryManager, error)
- func NewDummyServiceDiscoveryManager(_ context.Context, _ *katalystbase.GenericContext, ...) (ServiceDiscoveryManager, error)
- func NewPodSinglePortSDManager(ctx context.Context, agentCtx *katalystbase.GenericContext, ...) (ServiceDiscoveryManager, error)
- func NewServiceSinglePortSDManager(ctx context.Context, agentCtx *katalystbase.GenericContext, ...) (ServiceDiscoveryManager, error)
Constants ¶
View Source
const ServiceDiscoveryDummy = "dummy"
View Source
const ServiceDiscoveryPodSinglePort = "pod-single-port"
View Source
const ServiceDiscoveryServiceSinglePort = "service-single-port"
Variables ¶
This section is empty.
Functions ¶
func RegisterSDManagerInitializers ¶ added in v0.4.0
Types ¶
type DummyServiceDiscoveryManager ¶
type DummyServiceDiscoveryManager struct{}
func (DummyServiceDiscoveryManager) GetEndpoints ¶
func (d DummyServiceDiscoveryManager) GetEndpoints() ([]string, error)
func (DummyServiceDiscoveryManager) Name ¶ added in v0.4.0
func (d DummyServiceDiscoveryManager) Name() string
func (DummyServiceDiscoveryManager) Run ¶
func (d DummyServiceDiscoveryManager) Run() error
type InitFunc ¶ added in v0.4.0
type InitFunc func(ctx context.Context, agentCtx *katalystbase.GenericContext, conf *generic.ServiceDiscoveryConf) (ServiceDiscoveryManager, error)
type ServiceDiscoveryManager ¶
type ServiceDiscoveryManager interface { Name() string Run() error // GetEndpoints get all endpoints list in the format `host:port`, // different implementations may have each individual explanations // for what the returned value represents for. GetEndpoints() ([]string, error) }
ServiceDiscoveryManager is used to discover all available endpoints.
func GetSDManager ¶ added in v0.4.0
func GetSDManager(ctx context.Context, agentCtx *katalystbase.GenericContext, conf *generic.ServiceDiscoveryConf) (ServiceDiscoveryManager, error)
GetSDManager return an implementation for ServiceDiscoveryManager based on the given parameters
func NewDummyServiceDiscoveryManager ¶ added in v0.4.0
func NewDummyServiceDiscoveryManager(_ context.Context, _ *katalystbase.GenericContext, _ *generic.ServiceDiscoveryConf) (ServiceDiscoveryManager, error)
func NewPodSinglePortSDManager ¶ added in v0.4.0
func NewPodSinglePortSDManager(ctx context.Context, agentCtx *katalystbase.GenericContext, conf *generic.ServiceDiscoveryConf) (ServiceDiscoveryManager, error)
func NewServiceSinglePortSDManager ¶ added in v0.4.0
func NewServiceSinglePortSDManager(ctx context.Context, agentCtx *katalystbase.GenericContext, conf *generic.ServiceDiscoveryConf) (ServiceDiscoveryManager, error)
Click to show internal directories.
Click to hide internal directories.