service_discovery

Documentation

Index

• type DummyServiceDiscoveryManager
  • func (d DummyServiceDiscoveryManager) GetEndpoints() ([]string, error)
  • func (d DummyServiceDiscoveryManager) Run() error
• type ServiceDiscoveryManager
  • func NewPodInformerServiceDiscoveryManager(ctx context.Context, client kubernetes.Interface, podSelector labels.Selector, ...) ServiceDiscoveryManager

Types

type DummyServiceDiscoveryManager

type DummyServiceDiscoveryManager struct{}

func (DummyServiceDiscoveryManager) GetEndpoints

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

func (DummyServiceDiscoveryManager) Run

func (d DummyServiceDiscoveryManager) Run() error

type ServiceDiscoveryManager

type ServiceDiscoveryManager interface {
	// GetEndpoints get all endpoints list in the format `host:port`
	GetEndpoints() ([]string, error)

	// Run starts the service discovery manager
	Run() error
}

ServiceDiscoveryManager is used to discover all available endpoints.

func NewPodInformerServiceDiscoveryManager

func NewPodInformerServiceDiscoveryManager(ctx context.Context, client kubernetes.Interface,
	podSelector labels.Selector, portName string) ServiceDiscoveryManager