k8s

Documentation

Index

• func NewClientSet(kubeConfig string) (*kubernetes.Clientset, error)
• type API
  • func NewAPI(k8sClient kubernetes.Interface, resources ...ApiResource) *API
  • func NewFakeAPI(configs ...string) (*API, error)
  • func (api *API) CM() coreinformers.ConfigMapInformer
  • func (api *API) Deploy() appinformers.DeploymentInformer
  • func (api *API) Endpoint() coreinformers.EndpointsInformer
  • func (api *API) GetObjects(namespace, restype, name string) ([]runtime.Object, error)
  • func (api *API) GetPodsFor(obj runtime.Object, includeFailed bool) ([]*apiv1.Pod, error)
  • func (api *API) NS() coreinformers.NamespaceInformer
  • func (api *API) Pod() coreinformers.PodInformer
  • func (api *API) RC() coreinformers.ReplicationControllerInformer
  • func (api *API) RS() appinformers.ReplicaSetInformer
  • func (api *API) Svc() coreinformers.ServiceInformer
  • func (api *API) Sync() error
• type ApiResource

Functions

func NewClientSet

func NewClientSet(kubeConfig string) (*kubernetes.Clientset, error)

Types

type API

type API struct {
	Client kubernetes.Interface
	// contains filtered or unexported fields
}

API provides shared informers for all Kubernetes objects

func NewAPI

func NewAPI(k8sClient kubernetes.Interface, resources ...ApiResource) *API

NewAPI takes a Kubernetes client and returns an initialized API

func NewFakeAPI

func NewFakeAPI(configs ...string) (*API, error)

func (*API) CM

func (api *API) CM() coreinformers.ConfigMapInformer

func (*API) Deploy

func (api *API) Deploy() appinformers.DeploymentInformer

func (*API) Endpoint

func (api *API) Endpoint() coreinformers.EndpointsInformer

func (*API) GetObjects

func (api *API) GetObjects(namespace, restype, name string) ([]runtime.Object, error)

GetObjects returns a list of Kubernetes objects, given a namespace, type, and name. If namespace is an empty string, match objects in all namespaces. If name is an empty string, match all objects of the given type.

func (*API) GetPodsFor

func (api *API) GetPodsFor(obj runtime.Object, includeFailed bool) ([]*apiv1.Pod, error)

GetPodsFor returns all running and pending Pods associated with a given Kubernetes object. Use includeFailed to also get failed Pods

func (*API) NS

func (api *API) NS() coreinformers.NamespaceInformer

func (*API) Pod

func (api *API) Pod() coreinformers.PodInformer

func (*API) RC

func (api *API) RC() coreinformers.ReplicationControllerInformer

func (*API) RS

func (api *API) RS() appinformers.ReplicaSetInformer

func (*API) Svc

func (api *API) Svc() coreinformers.ServiceInformer

func (*API) Sync

func (api *API) Sync() error

Sync waits for all informers to be synced. For servers, call this asynchronously. For testing, call this synchronously.

type ApiResource

type ApiResource int

const (
	CM ApiResource = iota
	Deploy
	Endpoint
	NS
	Pod
	RC
	RS
	Svc
)