k8s

Documentation

Index

• func NewClientSet(kubeConfig string) (*kubernetes.Clientset, error)
• type EndpointsListener
• type EndpointsWatcher
  • func NewEndpointsWatcher(clientset *kubernetes.Clientset) *EndpointsWatcher
  • func (e *EndpointsWatcher) Run()
  • func (e *EndpointsWatcher) Stop()
  • func (e *EndpointsWatcher) Subscribe(service string, port uint32, listener EndpointsListener) error
  • func (e *EndpointsWatcher) Unsubscribe(service string, port uint32, listener EndpointsListener) error
• type PodIndex
  • func NewPodIndex(clientset *kubernetes.Clientset, index cache.IndexFunc) (*PodIndex, error)
  • func (p *PodIndex) GetPod(key string) (*v1.Pod, error)
  • func (p *PodIndex) GetPodsByIndex(key string) ([]*v1.Pod, error)
  • func (p *PodIndex) List() ([]*v1.Pod, error)
  • func (p *PodIndex) Run()
  • func (p *PodIndex) Stop()
• type ReplicaSetStore
  • func NewReplicaSetStore(clientset *kubernetes.Clientset) (*ReplicaSetStore, error)
  • func (p *ReplicaSetStore) GetDeploymentForPod(pod *v1.Pod) (string, error)
  • func (p *ReplicaSetStore) GetReplicaSet(key string) (*v1beta1.ReplicaSet, error)
  • func (p *ReplicaSetStore) Run()
  • func (p *ReplicaSetStore) Stop()

Functions

func NewClientSet

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

Types

type EndpointsListener

type EndpointsListener interface {
	Update(add []common.TcpAddress, remove []common.TcpAddress)
}

type EndpointsWatcher

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

func NewEndpointsWatcher

func NewEndpointsWatcher(clientset *kubernetes.Clientset) *EndpointsWatcher

An EndpointsWatcher watches all endpoints and services in the Kubernetes cluster. Listeners can subscribe to a particular service and port and EndpointsWatcher will publish the address set and all future changes for that service:port.

func (*EndpointsWatcher) Run

func (e *EndpointsWatcher) Run()

func (*EndpointsWatcher) Stop

func (e *EndpointsWatcher) Stop()

func (*EndpointsWatcher) Subscribe

func (e *EndpointsWatcher) Subscribe(service string, port uint32, listener EndpointsListener) error

Subscribe to a service and service port. The provided listener will be updated each time the address set for the given service port is changed.

func (*EndpointsWatcher) Unsubscribe

func (e *EndpointsWatcher) Unsubscribe(service string, port uint32, listener EndpointsListener) error

type PodIndex

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

func NewPodIndex

func NewPodIndex(clientset *kubernetes.Clientset, index cache.IndexFunc) (*PodIndex, error)

func (*PodIndex) GetPod

func (p *PodIndex) GetPod(key string) (*v1.Pod, error)

func (*PodIndex) GetPodsByIndex

func (p *PodIndex) GetPodsByIndex(key string) ([]*v1.Pod, error)

func (*PodIndex) List

func (p *PodIndex) List() ([]*v1.Pod, error)

func (*PodIndex) Run

func (p *PodIndex) Run()

func (*PodIndex) Stop

func (p *PodIndex) Stop()

type ReplicaSetStore

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

func NewReplicaSetStore

func NewReplicaSetStore(clientset *kubernetes.Clientset) (*ReplicaSetStore, error)

func (*ReplicaSetStore) GetDeploymentForPod

func (p *ReplicaSetStore) GetDeploymentForPod(pod *v1.Pod) (string, error)

func (*ReplicaSetStore) GetReplicaSet

func (p *ReplicaSetStore) GetReplicaSet(key string) (*v1beta1.ReplicaSet, error)

func (*ReplicaSetStore) Run

func (p *ReplicaSetStore) Run()

func (*ReplicaSetStore) Stop

func (p *ReplicaSetStore) Stop()