controller

Documentation

Index

• type Config
• type Controller
  • func New(config Config, k8sCli kubernetes.Interface, logger log.Logger) (*Controller, error)
• type PodRetrieve
  • func NewPodRetrieve(namespace string, client kubernetes.Interface) *PodRetrieve
  • func (p *PodRetrieve) GetListerWatcher() cache.ListerWatcher
  • func (p *PodRetrieve) GetObject() runtime.Object

Types

type Config

type Config struct {
	ResyncPeriod time.Duration
	Namespace    string
}

Config is the controller configuration.

type Controller

type Controller struct {
	controller.Controller
	// contains filtered or unexported fields
}

Controller is a controller that echoes pod events.

func New

func New(config Config, k8sCli kubernetes.Interface, logger log.Logger) (*Controller, error)

New returns a new Echo controller.

type PodRetrieve

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

PodRetrieve knows how to retrieve pods.

func NewPodRetrieve

func NewPodRetrieve(namespace string, client kubernetes.Interface) *PodRetrieve

NewPodRetrieve returns a new pod retriever.

func (*PodRetrieve) GetListerWatcher

func (p *PodRetrieve) GetListerWatcher() cache.ListerWatcher

GetListerWatcher knows how to return a listerWatcher of a pod.

func (*PodRetrieve) GetObject

func (p *PodRetrieve) GetObject() runtime.Object

GetObject returns the empty pod.