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 Lister
  • func NewLister(k8sClient kubernetes.Interface) *Lister
  • func (l *Lister) GetObjects(namespace, restype, name string) ([]runtime.Object, error)
  • func (l *Lister) GetPodsFor(obj runtime.Object) ([]*apiv1.Pod, error)
  • func (l *Lister) Sync() error
• 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.Interface, index cache.IndexFunc) (PodIndex, error)
  • func NewPodsByIp(clientSet *kubernetes.Clientset) (PodIndex, error)

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 Lister

type Lister struct {
	NS     corelisters.NamespaceLister
	Deploy applisters.DeploymentLister
	RS     applisters.ReplicaSetLister
	Pod    corelisters.PodLister
	RC     corelisters.ReplicationControllerLister
	Svc    corelisters.ServiceLister
	// contains filtered or unexported fields
}

Lister wraps client-go Lister types for all Kubernetes objects

func NewLister

func NewLister(k8sClient kubernetes.Interface) *Lister

NewLister takes a Kubernetes client and returns an initialized Lister

func (*Lister) GetObjects

func (l *Lister) 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 (*Lister) GetPodsFor

func (l *Lister) GetPodsFor(obj runtime.Object) ([]*apiv1.Pod, error)

GetPodsFor returns all running and pending Pods associated with a given Kubernetes object.

func (*Lister) Sync

func (l *Lister) Sync() error

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

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.Interface, 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.