kubernetes

Documentation

Index

• type AppService
  • func (k *AppService) Client() (*kubernetes.Clientset, error)
  • func (k *AppService) DynamicClient() (*dynamic.DynamicClient, error)
  • func (k *AppService) GetDaemonSetsSets(name, namespace string) (*appsV1.DaemonSet, error)
  • func (k *AppService) GetDeployments(name, namespace string) (*appsV1.Deployment, error)
  • func (k *AppService) GetPod(name, namespace string) (*coreV1.Pod, error)
  • func (k *AppService) GetPodFromIp(ip, namespace, labelSelector, fieldSelector string) (*coreV1.Pod, error)
  • func (k *AppService) GetPodFromName(name, namespace, labelSelector, fieldSelector string) (*coreV1.Pod, error)
  • func (k *AppService) GetStatefulSets(name, namespace string) (*appsV1.StatefulSet, error)
  • func (k *AppService) ListDaemonSets(namespace, labelSelector, fieldSelector string) (*appsV1.DaemonSetList, error)
  • func (k *AppService) ListDeployments(namespace, labelSelector, fieldSelector string) (*appsV1.DeploymentList, error)
  • func (k *AppService) ListEvents(namespace, labelSelector, fieldSelector string) (*eventsV1.EventList, error)
  • func (k *AppService) ListIngresses(namespace, labelSelector, fieldSelector string) (*networkingV1.IngressList, error)
  • func (k *AppService) ListPods(namespace, labelSelector, fieldSelector string) (*coreV1.PodList, error)
  • func (k *AppService) ListStatefulSets(namespace, labelSelector, fieldSelector string) (*appsV1.StatefulSetList, error)
  • func (k *AppService) PatchDeployments(name, namespace string, MergePatchTypeData []byte, dryRun bool) (*appsV1.Deployment, error)
  • func (k *AppService) PatchPod(name, namespace string, MergePatchTypeData []byte, dryRun bool) (*coreV1.Pod, error)
  • func (k *AppService) ServicesList(namespace, labelSelector, fieldSelector string) (*coreV1.ServiceList, error)
  • func (k *AppService) UpdateDeployments(namespace string, deployments *appsV1.Deployment, dryRun bool) (*appsV1.Deployment, error)
  • func (k *AppService) UpdatePod(namespace string, pod *coreV1.Pod, dryRun bool) (*coreV1.Pod, error)
  • func (k *AppService) WatchDaemonSets() (chan struct{}, error)
  • func (k *AppService) WatchDeployments() (chan struct{}, error)
  • func (k *AppService) WatchPods() (chan struct{}, error)
  • func (k *AppService) WatchPodsRestart(handler *EventHandlerPodsRestart) (chan struct{}, error)
  • func (k *AppService) WatchStatefulSets() (chan struct{}, error)
• type EventHandler
  • func NewEventHandler() *EventHandler
  • func (e *EventHandler) OnAdd(obj interface{})
  • func (e *EventHandler) OnDelete(obj interface{})
  • func (e *EventHandler) OnUpdate(oldObj, newObj interface{})
• type EventHandlerPodsRestart
  • func NewEventHandlerPodsRestart() *EventHandlerPodsRestart
  • func (e *EventHandlerPodsRestart) OnAdd(obj interface{})
  • func (e *EventHandlerPodsRestart) OnDelete(obj interface{})
  • func (e *EventHandlerPodsRestart) OnUpdate(oldObj, newObj interface{})

Types

type AppService

type AppService struct {
	Host  string
	Token string
}

func (*AppService) Client

func (k *AppService) Client() (*kubernetes.Clientset, error)

func (*AppService) DynamicClient

func (k *AppService) DynamicClient() (*dynamic.DynamicClient, error)

func (*AppService) GetDaemonSetsSets

func (k *AppService) GetDaemonSetsSets(name, namespace string) (*appsV1.DaemonSet, error)

func (*AppService) GetDeployments

func (k *AppService) GetDeployments(name, namespace string) (*appsV1.Deployment, error)

func (*AppService) GetPod

func (k *AppService) GetPod(name, namespace string) (*coreV1.Pod, error)

func (*AppService) GetPodFromIp

func (k *AppService) GetPodFromIp(ip, namespace, labelSelector, fieldSelector string) (*coreV1.Pod, error)

func (*AppService) GetPodFromName

func (k *AppService) GetPodFromName(name, namespace, labelSelector, fieldSelector string) (*coreV1.Pod, error)

func (*AppService) GetStatefulSets

func (k *AppService) GetStatefulSets(name, namespace string) (*appsV1.StatefulSet, error)

func (*AppService) ListDaemonSets

func (k *AppService) ListDaemonSets(namespace, labelSelector, fieldSelector string) (*appsV1.DaemonSetList, error)

func (*AppService) ListDeployments

func (k *AppService) ListDeployments(namespace, labelSelector, fieldSelector string) (*appsV1.DeploymentList, error)

func (*AppService) ListEvents

func (k *AppService) ListEvents(namespace, labelSelector, fieldSelector string) (*eventsV1.EventList, error)

func (*AppService) ListIngresses

func (k *AppService) ListIngresses(namespace, labelSelector, fieldSelector string) (*networkingV1.IngressList, error)

func (*AppService) ListPods

func (k *AppService) ListPods(namespace, labelSelector, fieldSelector string) (*coreV1.PodList, error)

func (*AppService) ListStatefulSets

func (k *AppService) ListStatefulSets(namespace, labelSelector, fieldSelector string) (*appsV1.StatefulSetList, error)

func (*AppService) PatchDeployments

func (k *AppService) PatchDeployments(name, namespace string, MergePatchTypeData []byte, dryRun bool) (*appsV1.Deployment, error)

PatchDeployments name: DeploymentsName, namespace: namespace, MergePatchTypeData: []byte(`{"metadata":{"labels":{"tag":"test"}}}`)

func (*AppService) PatchPod

func (k *AppService) PatchPod(name, namespace string, MergePatchTypeData []byte, dryRun bool) (*coreV1.Pod, error)

func (*AppService) ServicesList

func (k *AppService) ServicesList(namespace, labelSelector, fieldSelector string) (*coreV1.ServiceList, error)

func (*AppService) UpdateDeployments

func (k *AppService) UpdateDeployments(namespace string, deployments *appsV1.Deployment, dryRun bool) (*appsV1.Deployment, error)

func (*AppService) UpdatePod

func (k *AppService) UpdatePod(namespace string, pod *coreV1.Pod, dryRun bool) (*coreV1.Pod, error)

func (*AppService) WatchDaemonSets

func (k *AppService) WatchDaemonSets() (chan struct{}, error)

func (*AppService) WatchDeployments

func (k *AppService) WatchDeployments() (chan struct{}, error)

func (*AppService) WatchPods

func (k *AppService) WatchPods() (chan struct{}, error)

func (*AppService) WatchPodsRestart

func (k *AppService) WatchPodsRestart(handler *EventHandlerPodsRestart) (chan struct{}, error)

func (*AppService) WatchStatefulSets

func (k *AppService) WatchStatefulSets() (chan struct{}, error)

type EventHandler

type EventHandler struct {
}

func NewEventHandler

func NewEventHandler() *EventHandler

func (*EventHandler) OnAdd

func (e *EventHandler) OnAdd(obj interface{})

func (*EventHandler) OnDelete

func (e *EventHandler) OnDelete(obj interface{})

func (*EventHandler) OnUpdate

func (e *EventHandler) OnUpdate(oldObj, newObj interface{})

type EventHandlerPodsRestart

type EventHandlerPodsRestart struct {
}

func NewEventHandlerPodsRestart

func NewEventHandlerPodsRestart() *EventHandlerPodsRestart

func (*EventHandlerPodsRestart) OnAdd

func (e *EventHandlerPodsRestart) OnAdd(obj interface{})

func (*EventHandlerPodsRestart) OnDelete

func (e *EventHandlerPodsRestart) OnDelete(obj interface{})

func (*EventHandlerPodsRestart) OnUpdate

func (e *EventHandlerPodsRestart) OnUpdate(oldObj, newObj interface{})