k8s

Documentation

Index

• type Client
  • func NewKubernetesClient(kubeconfigPath string) (*Client, error)
  • func (client *Client) GetNamespaces() (*v1.NamespaceList, error)
  • func (client *Client) GetNodes() (*v1.NodeList, error)
  • func (client *Client) GetPods() (*v1.PodList, error)
  • func (client *Client) GetServices() (*v1.ServiceList, error)
• type Watcher
  • func NewKubernetesWatcher(clientset *kubernetes.Clientset, out chan messages.Message) (*Watcher, error)
  • func (watcher *Watcher) Watch()

Types

type Client

type Client struct {
	Clientset *kubernetes.Clientset
}

Client define a Kubernetes client.

func NewKubernetesClient

func NewKubernetesClient(kubeconfigPath string) (*Client, error)

NewKubernetesClient create new Kubernetes client using configuration from kubectl.

func (*Client) GetNamespaces

func (client *Client) GetNamespaces() (*v1.NamespaceList, error)

func (*Client) GetNodes

func (client *Client) GetNodes() (*v1.NodeList, error)

func (*Client) GetPods

func (client *Client) GetPods() (*v1.PodList, error)

func (*Client) GetServices

func (client *Client) GetServices() (*v1.ServiceList, error)

type Watcher

type Watcher struct {
	Pods      watch.Interface
	Services  watch.Interface
	Endpoints watch.Interface
	Out       chan messages.Message
}

Watcher define a Kubernetes watching resources

func NewKubernetesWatcher

func NewKubernetesWatcher(clientset *kubernetes.Clientset, out chan messages.Message) (*Watcher, error)

func (*Watcher) Watch

func (watcher *Watcher) Watch()