service_discovery

Documentation

Index

• Constants
• func RegisterSDManagerInitializers(name string, initFunc InitFunc)
• type DummyServiceDiscoveryManager
  • func (d DummyServiceDiscoveryManager) GetEndpoints() ([]string, error)
  • func (d DummyServiceDiscoveryManager) Name() string
  • func (d DummyServiceDiscoveryManager) Run() error
• 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

const ServiceDiscoveryDummy = "dummy"

const ServiceDiscoveryPodSinglePort = "pod-single-port"

const ServiceDiscoveryServiceSinglePort = "service-single-port"

Functions

func RegisterSDManagerInitializers

func RegisterSDManagerInitializers(name string, initFunc InitFunc)

Types

type DummyServiceDiscoveryManager

type DummyServiceDiscoveryManager struct{}

func (DummyServiceDiscoveryManager) GetEndpoints

func (d DummyServiceDiscoveryManager) GetEndpoints() ([]string, error)

func (DummyServiceDiscoveryManager) Name

func (d DummyServiceDiscoveryManager) Name() string

func (DummyServiceDiscoveryManager) Run

func (d DummyServiceDiscoveryManager) Run() error

type InitFunc

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

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

func NewDummyServiceDiscoveryManager(_ context.Context, _ *katalystbase.GenericContext,
	_ *generic.ServiceDiscoveryConf,
) (ServiceDiscoveryManager, error)

func NewPodSinglePortSDManager

func NewPodSinglePortSDManager(ctx context.Context, agentCtx *katalystbase.GenericContext,
	conf *generic.ServiceDiscoveryConf,
) (ServiceDiscoveryManager, error)

func NewServiceSinglePortSDManager

func NewServiceSinglePortSDManager(ctx context.Context, agentCtx *katalystbase.GenericContext,
	conf *generic.ServiceDiscoveryConf,
) (ServiceDiscoveryManager, error)