statesinformer

Documentation

Index

• type Config
  • func NewDefaultConfig() *Config
  • func (c *Config) InitFlags(fs *flag.FlagSet)
• type KubeletStub
  • func NewKubeletStub(ip string, port, timeoutSeconds int) KubeletStub
• type PodMeta
  • func (in *PodMeta) DeepCopy() *PodMeta
• type StatesInformer
  • func NewMetaService(config *Config, kubeClient clientset.Interface, pleg pleg.Pleg, ...) StatesInformer

Types

type Config

type Config struct {
	KubeletIPAddr              string
	KubeletHTTPPort            int
	KubeletSyncIntervalSeconds int
	KubeletSyncTimeoutSeconds  int
}

func NewDefaultConfig

func NewDefaultConfig() *Config

func (*Config) InitFlags

func (c *Config) InitFlags(fs *flag.FlagSet)

type KubeletStub

type KubeletStub interface {
	GetAllPods() (corev1.PodList, error)
}

func NewKubeletStub

func NewKubeletStub(ip string, port, timeoutSeconds int) KubeletStub

type PodMeta

type PodMeta struct {
	Pod       *corev1.Pod
	CgroupDir string
}

func (*PodMeta) DeepCopy

func (in *PodMeta) DeepCopy() *PodMeta

type StatesInformer

type StatesInformer interface {
	Run(stopCh <-chan struct{}) error
	HasSynced() bool

	GetNode() *corev1.Node

	GetAllPods() []*PodMeta
}

func NewMetaService

func NewMetaService(config *Config, kubeClient clientset.Interface, pleg pleg.Pleg, nodeName string) StatesInformer