Versions in this module Expand all Collapse all v0 v0.1.1 Dec 20, 2017 v0.1.0 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()
Go to main page