kubernetes

Documentation

Index

• type Discovery
  • func New(l log.Logger, conf *config.KubernetesSDConfig) (*Discovery, error)
  • func (d *Discovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)
• type Endpoints
  • func NewEndpoints(l log.Logger, svc, eps, pod cache.SharedInformer) *Endpoints
  • func (e *Endpoints) Run(ctx context.Context, ch chan<- []*config.TargetGroup)
• type Node
  • func NewNode(l log.Logger, inf cache.SharedInformer) *Node
  • func (n *Node) Run(ctx context.Context, ch chan<- []*config.TargetGroup)
• type Pod
  • func NewPod(l log.Logger, pods cache.SharedInformer) *Pod
  • func (p *Pod) Run(ctx context.Context, ch chan<- []*config.TargetGroup)
• type Service
  • func NewService(l log.Logger, inf cache.SharedInformer) *Service
  • func (s *Service) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Types

type Discovery

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

Discovery implements the TargetProvider interface for discovering targets from Kubernetes.

func New

func New(l log.Logger, conf *config.KubernetesSDConfig) (*Discovery, error)

New creates a new Kubernetes discovery for the given role.

func (*Discovery) Run

func (d *Discovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.

type Endpoints

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

Endpoints discovers new endpoint targets.

func NewEndpoints

func NewEndpoints(l log.Logger, svc, eps, pod cache.SharedInformer) *Endpoints

NewEndpoints returns a new endpoints discovery.

func (*Endpoints) Run

func (e *Endpoints) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the retrieval.TargetProvider interface.

type Node

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

Node discovers Kubernetes nodes.

func NewNode

func NewNode(l log.Logger, inf cache.SharedInformer) *Node

NewNode returns a new node discovery.

func (*Node) Run

func (n *Node) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.

type Pod

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

Pod discovers new pod targets.

func NewPod

func NewPod(l log.Logger, pods cache.SharedInformer) *Pod

NewPod creates a new pod discovery.

func (*Pod) Run

func (p *Pod) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.

type Service

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

Service implements discovery of Kubernetes services.

func NewService

func NewService(l log.Logger, inf cache.SharedInformer) *Service

NewService returns a new service discovery.

func (*Service) Run

func (s *Service) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.