k8s

Documentation

Index

• Variables
• func GetKubeClient() (*kubernetes.Clientset, error)
• func GetKubeConfig() (*rest.Config, error)
• func HomeDir() string
• func NewK8sAPIServer(pr PodRegistry) k8sApi.K8SDaemonServer
• type ForEachHandler
• type PodRegistry
  • func NewPodRegistry() PodRegistry

Variables

var KubeConfigPathFlag *string

Functions

func GetKubeClient

func GetKubeClient() (*kubernetes.Clientset, error)

func GetKubeConfig

func GetKubeConfig() (*rest.Config, error)

func HomeDir

func HomeDir() string

func NewK8sAPIServer

func NewK8sAPIServer(pr PodRegistry) k8sApi.K8SDaemonServer

Types

type ForEachHandler

type ForEachHandler func(key string, pod v1.Pod)

type PodRegistry

type PodRegistry interface {
	AddPod(pod v1.Pod)
	GetPod(key string) (v1.Pod, bool)
	RemovePod(pod v1.Pod)
	ForEach(handler ForEachHandler)
}

func NewPodRegistry

func NewPodRegistry() PodRegistry