k8s

Documentation

Index

• type PodController
  • func NewPodController(logger *slog.Logger, clientset *kubernetes.Clientset, handler PodHandler, ...) (*PodController, error)
  • func (c *PodController) Run(stopCh <-chan struct{})
• type PodControllerConfig
• type PodHandler

Types

type PodController

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

func NewPodController

func NewPodController(logger *slog.Logger, clientset *kubernetes.Clientset, handler PodHandler, config PodControllerConfig) (*PodController, error)

func (*PodController) Run

func (c *PodController) Run(stopCh <-chan struct{})

type PodControllerConfig

type PodControllerConfig struct {
	Namespace    string
	ResyncPeriod time.Duration
}

type PodHandler

type PodHandler interface {
	AddOrUpdate(key string, pod v1.Pod) error
	Delete(key string) error
}