kube

Documentation

Index

• type CacheController
  • func NewController(client rest.Interface, resourceType rt.Object, resource string, ...) CacheController
• type Client
  • func NewClusterCache(client *kubernetes.Clientset) Client
• type ClusterCache
  • func (cc *ClusterCache) GetPod(name, namespace string) *corev1.Pod
  • func (cc *ClusterCache) GetReplicaSet(name, namespace string) *appsv1.ReplicaSet
  • func (cc *ClusterCache) GetServices(labels map[string]string, namespace string) []*corev1.Service
  • func (cc *ClusterCache) Run()
  • func (cc *ClusterCache) Stop()
• type Controller
  • func (c *Controller) ListObjs() []interface{}
  • func (c *Controller) Run(stopCh chan struct{})

Types

type CacheController

type CacheController interface {
	Run(chan struct{})

	ListObjs() []interface{}
}

func NewController

func NewController(client rest.Interface, resourceType rt.Object, resource string, namespace string) CacheController

type Client

type Client interface {
	Run()
	Stop()

	GetPod(string, string) *corev1.Pod
	GetReplicaSet(string, string) *appsv1.ReplicaSet
	GetServices(map[string]string, string) []*corev1.Service
}

func NewClusterCache

func NewClusterCache(client *kubernetes.Clientset) Client

type ClusterCache

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

func (*ClusterCache) GetPod

func (cc *ClusterCache) GetPod(name, namespace string) *corev1.Pod

func (*ClusterCache) GetReplicaSet

func (cc *ClusterCache) GetReplicaSet(name, namespace string) *appsv1.ReplicaSet

func (*ClusterCache) GetServices

func (cc *ClusterCache) GetServices(labels map[string]string, namespace string) []*corev1.Service

func (*ClusterCache) Run

func (cc *ClusterCache) Run()

func (*ClusterCache) Stop

func (cc *ClusterCache) Stop()

type Controller

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

func (*Controller) ListObjs

func (c *Controller) ListObjs() []interface{}

func (*Controller) Run

func (c *Controller) Run(stopCh chan struct{})