controller

Documentation

Index

• type Controller
  • func NewController(informer cache.SharedIndexInformer, conf *config.Config, ...) (Controller, error)
• type ControllerClient

Types

type Controller

type Controller interface {
	GetClient(name string) (types.LokiClient, bool)
	Stop()
}

Controller represent a k8s controller watching for resources and create Loki clients base on them

func NewController

func NewController(informer cache.SharedIndexInformer, conf *config.Config, defaultClient types.LokiClient, logger log.Logger) (Controller, error)

NewController return Controller interface

type ControllerClient

type ControllerClient interface {
	types.LokiClient
	GetState() clusterState
	SetState(state clusterState)
}