k8s

Documentation

Index

• func NewClientSet(kubeConfig string) (*kubernetes.Clientset, error)
• type EndpointsListener
• type EndpointsWatcher
  • func NewEndpointsWatcher(clientset *kubernetes.Clientset) EndpointsWatcher
• type InMemoryPodIndex
  • func (i *InMemoryPodIndex) GetPod(key string) (*v1.Pod, error)
  • func (i *InMemoryPodIndex) GetPodsByIndex(key string) ([]*v1.Pod, error)
  • func (i *InMemoryPodIndex) List() ([]*v1.Pod, error)
  • func (i *InMemoryPodIndex) Run() error
  • func (i *InMemoryPodIndex) Stop()
• type MockEndpointsWatcher
  • func (m *MockEndpointsWatcher) GetService(service string) (*v1.Service, bool, error)
  • func (m *MockEndpointsWatcher) Run() error
  • func (m *MockEndpointsWatcher) Stop()
  • func (m *MockEndpointsWatcher) Subscribe(service string, port uint32, listener EndpointsListener) error
  • func (m *MockEndpointsWatcher) Unsubscribe(service string, port uint32, listener EndpointsListener) error
• type PodIndex
  • func NewEmptyPodIndex() PodIndex
  • func NewPodIndex(clientset *kubernetes.Clientset, index cache.IndexFunc) (PodIndex, error)
  • func NewPodsByIp(clientSet *kubernetes.Clientset) (PodIndex, error)
• 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() error
  • 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)
	NoEndpoints(exists bool)
}

type EndpointsWatcher

type EndpointsWatcher interface {
	GetService(service string) (*v1.Service, bool, error)
	Subscribe(service string, port uint32, listener EndpointsListener) error
	Unsubscribe(service string, port uint32, listener EndpointsListener) error
	Run() error
	Stop()
}

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.

type InMemoryPodIndex

type InMemoryPodIndex struct {
	BackingMap map[string]*v1.Pod
}

func (*InMemoryPodIndex) GetPod

func (i *InMemoryPodIndex) GetPod(key string) (*v1.Pod, error)

func (*InMemoryPodIndex) GetPodsByIndex

func (i *InMemoryPodIndex) GetPodsByIndex(key string) ([]*v1.Pod, error)

func (*InMemoryPodIndex) List

func (i *InMemoryPodIndex) List() ([]*v1.Pod, error)

func (*InMemoryPodIndex) Run

func (i *InMemoryPodIndex) Run() error

func (*InMemoryPodIndex) Stop

func (i *InMemoryPodIndex) Stop()

type MockEndpointsWatcher

type MockEndpointsWatcher struct {
	HostReceived         string
	ListenerSubscribed   EndpointsListener
	ListenerUnsubscribed EndpointsListener
	ServiceToReturn      *v1.Service
	ExistsToReturn       bool
	ErrToReturn          error
}

func (*MockEndpointsWatcher) GetService

func (m *MockEndpointsWatcher) GetService(service string) (*v1.Service, bool, error)

func (*MockEndpointsWatcher) Run

func (m *MockEndpointsWatcher) Run() error

func (*MockEndpointsWatcher) Stop

func (m *MockEndpointsWatcher) Stop()

func (*MockEndpointsWatcher) Subscribe

func (m *MockEndpointsWatcher) Subscribe(service string, port uint32, listener EndpointsListener) error

func (*MockEndpointsWatcher) Unsubscribe

func (m *MockEndpointsWatcher) Unsubscribe(service string, port uint32, listener EndpointsListener) error

type PodIndex

type PodIndex interface {
	GetPod(key string) (*v1.Pod, error)
	GetPodsByIndex(key string) ([]*v1.Pod, error)
	List() ([]*v1.Pod, error)
	Run() error
	Stop()
}

func NewEmptyPodIndex

func NewEmptyPodIndex() PodIndex

func NewPodIndex

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

func NewPodsByIp

func NewPodsByIp(clientSet *kubernetes.Clientset) (PodIndex, error)

NewPodsByIp returns a PodIndex with the Pod's IP as its key.

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)

GetDeploymentForPod returns pod owner information: if the pod's replicaset belongs to a deployment: "namespace/deployment" if the pod's replicaset does not belong to a deployment: "namespace/replicaset"

func (*ReplicaSetStore) GetReplicaSet

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

func (*ReplicaSetStore) Run

func (p *ReplicaSetStore) Run() error

func (*ReplicaSetStore) Stop

func (p *ReplicaSetStore) Stop()