k8s

Apr 16, 2018

Changes in this version

type EndpointsListener

+ NoEndpoints func(exists bool)

+ type InMemoryPodIndex struct

+ BackingMap map[string]*v1.Pod

+ 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 struct

+ ErrToReturn error

+ ExistsToReturn bool

+ HostReceived string

+ ListenerSubscribed EndpointsListener

+ ListenerUnsubscribed EndpointsListener

+ ServiceToReturn *v1.Service

+ 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 NewPodsByIp(clientSet *kubernetes.Clientset) (PodIndex, error)

Mar 15, 2018

Changes in this version

type EndpointsWatcher

+ func (e *EndpointsWatcher) GetService(service string) (*v1.Service, bool, error)

Dec 5, 2017

Changes in this version

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

+ type EndpointsListener interface

+ Update func(add []common.TcpAddress, remove []common.TcpAddress)

+ type EndpointsWatcher struct

+ 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 struct

+ 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 struct

+ 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()