sd

Documentation

Index

• type K8SServiceDiscovery
  • func (sd *K8SServiceDiscovery) GetLabels(pid uint32) *spy.Labels
  • func (sd *K8SServiceDiscovery) Refresh(ctx context.Context) error
• type NoopServiceDiscovery
  • func (NoopServiceDiscovery) GetLabels(_ uint32) *spy.Labels
  • func (NoopServiceDiscovery) Refresh(_ context.Context) error
• type ServiceDiscovery
  • func NewK8ServiceDiscovery(ctx context.Context, logger log.Logger, nodeName string) (ServiceDiscovery, error)

Types

type K8SServiceDiscovery

type K8SServiceDiscovery struct {
	// contains filtered or unexported fields
}

func (*K8SServiceDiscovery) GetLabels

func (sd *K8SServiceDiscovery) GetLabels(pid uint32) *spy.Labels

func (*K8SServiceDiscovery) Refresh

func (sd *K8SServiceDiscovery) Refresh(ctx context.Context) error

type NoopServiceDiscovery

type NoopServiceDiscovery struct {
}

func (NoopServiceDiscovery) GetLabels

func (NoopServiceDiscovery) GetLabels(_ uint32) *spy.Labels

func (NoopServiceDiscovery) Refresh

func (NoopServiceDiscovery) Refresh(_ context.Context) error

type ServiceDiscovery

type ServiceDiscovery interface {
	// Refresh called every 10s before session reset
	Refresh(ctx context.Context) error

	// GetLabels may return nil
	GetLabels(pid uint32) *spy.Labels
}

func NewK8ServiceDiscovery

func NewK8ServiceDiscovery(ctx context.Context, logger log.Logger, nodeName string) (ServiceDiscovery, error)