kubernetes

Documentation

Index

• type Enabled
• type NodeOption
• type PluginConfig
• type PodWatcher
  • func NewPodWatcher(kubeClient *k8s.Client, indexers *kubernetes.Indexers, ...) *PodWatcher
  • func (p *PodWatcher) GetMetaData(arg string) common.MapStr
  • func (p *PodWatcher) GetPod(uid string) *kubernetes.Pod
  • func (p *PodWatcher) Run() bool
  • func (p *PodWatcher) Stop()

Types

type Enabled

type Enabled struct {
	Enabled bool `config:"enabled"`
}

type NodeOption

type NodeOption struct{}

type PluginConfig

type PluginConfig []map[string]*common.Config

type PodWatcher

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

PodWatcher is a controller that synchronizes Pods.

func NewPodWatcher

func NewPodWatcher(kubeClient *k8s.Client, indexers *kubernetes.Indexers, syncPeriod time.Duration, host string) *PodWatcher

NewPodWatcher initializes the watcher factory to provide a local state of runners from the cluster (filtered to the given host)

func (*PodWatcher) GetMetaData

func (p *PodWatcher) GetMetaData(arg string) common.MapStr

func (*PodWatcher) GetPod

func (p *PodWatcher) GetPod(uid string) *kubernetes.Pod

func (*PodWatcher) Run

func (p *PodWatcher) Run() bool

func (*PodWatcher) Stop

func (p *PodWatcher) Stop()