k8s

Jul 5, 2018

Changes in this version

type API

+ func (api *API) GetOwnerKindAndName(pod *apiv1.Pod) (string, string)

Jun 18, 2018

Changes in this version

+ type API struct

+ Client kubernetes.Interface

+ func NewAPI(k8sClient kubernetes.Interface, resources ...ApiResource) *API

+ func NewFakeAPI(configs ...string) (*API, error)

+ func (api *API) CM() coreinformers.ConfigMapInformer

+ func (api *API) Deploy() appinformers.DeploymentInformer

+ func (api *API) Endpoint() coreinformers.EndpointsInformer

+ func (api *API) GetObjects(namespace, restype, name string) ([]runtime.Object, error)

+ func (api *API) GetPodsFor(obj runtime.Object, includeFailed bool) ([]*apiv1.Pod, error)

+ func (api *API) NS() coreinformers.NamespaceInformer

+ func (api *API) Pod() coreinformers.PodInformer

+ func (api *API) RC() coreinformers.ReplicationControllerInformer

+ func (api *API) RS() appinformers.ReplicaSetInformer

+ func (api *API) Svc() coreinformers.ServiceInformer

+ func (api *API) Sync() error

+ type ApiResource int

+ const CM

+ const Deploy

+ const Endpoint

+ const NS

+ const Pod

+ const RC

+ const RS

+ const Svc

Apr 26, 2018

Changes in this version

+ type Lister struct

+ Deploy applisters.DeploymentLister

+ NS corelisters.NamespaceLister

+ Pod corelisters.PodLister

+ RC corelisters.ReplicationControllerLister

+ RS applisters.ReplicaSetLister

+ Svc corelisters.ServiceLister

+ 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

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