kubernetes

Documentation

Index

• func GetUniqueLabelSets(svc *kubev1.Service, pods []*kubev1.Pod) []map[string]string
• func GetUniqueLabelSetsForObjects(selector map[string]string, podlabelss []map[string]string) []map[string]string
• func NewPlugin(kube kubernetes.Interface) plugins.Plugin
• func UpdateUpstream(original, desired *v1.Upstream) (bool, error)
• func UpstreamName(serviceNamespace, serviceName string, servicePort int32, ...) string
• type KubePluginListers
  • func (k *KubePluginListers) EndpointsLister() kubelisters.EndpointsLister
  • func (k *KubePluginListers) PodsLister() kubelisters.PodLister
  • func (k *KubePluginListers) ServicesLister() kubelisters.ServiceLister
  • func (k *KubePluginListers) Subscribe() <-chan struct{}
  • func (k *KubePluginListers) Unsubscribe(c <-chan struct{})
• type KubePluginSharedFactory
• type KubeUpstreamConverter
  • func DefaultUpstreamConverter() *KubeUpstreamConverter
  • func (uc *KubeUpstreamConverter) CreateUpstreamForLabels(ctx context.Context, uniqueLabelSets []map[string]string, svc *kubev1.Service) v1.UpstreamList
  • func (uc *KubeUpstreamConverter) UpstreamsForService(ctx context.Context, svc *kubev1.Service, pods []*kubev1.Pod) v1.UpstreamList
• type UpstreamConverter

Functions

func GetUniqueLabelSets

func GetUniqueLabelSets(svc *kubev1.Service, pods []*kubev1.Pod) []map[string]string

func GetUniqueLabelSetsForObjects

func GetUniqueLabelSetsForObjects(selector map[string]string, podlabelss []map[string]string) []map[string]string

func NewPlugin

func NewPlugin(kube kubernetes.Interface) plugins.Plugin

func UpdateUpstream

func UpdateUpstream(original, desired *v1.Upstream) (bool, error)

func UpstreamName

func UpstreamName(serviceNamespace, serviceName string, servicePort int32, extraLabels map[string]string) string

Types

type KubePluginListers

type KubePluginListers struct {
	// contains filtered or unexported fields
}

func (*KubePluginListers) EndpointsLister

func (k *KubePluginListers) EndpointsLister() kubelisters.EndpointsLister

func (*KubePluginListers) PodsLister

func (k *KubePluginListers) PodsLister() kubelisters.PodLister

func (*KubePluginListers) ServicesLister

func (k *KubePluginListers) ServicesLister() kubelisters.ServiceLister

func (*KubePluginListers) Subscribe

func (k *KubePluginListers) Subscribe() <-chan struct{}

func (*KubePluginListers) Unsubscribe

func (k *KubePluginListers) Unsubscribe(c <-chan struct{})

type KubePluginSharedFactory

type KubePluginSharedFactory interface {
	EndpointsLister() kubelisters.EndpointsLister
	ServicesLister() kubelisters.ServiceLister
	PodsLister() kubelisters.PodLister
	Subscribe() <-chan struct{}
	Unsubscribe(<-chan struct{})
}

type KubeUpstreamConverter

type KubeUpstreamConverter struct {
	// contains filtered or unexported fields
}

func DefaultUpstreamConverter

func DefaultUpstreamConverter() *KubeUpstreamConverter

func (*KubeUpstreamConverter) CreateUpstreamForLabels

func (uc *KubeUpstreamConverter) CreateUpstreamForLabels(ctx context.Context, uniqueLabelSets []map[string]string, svc *kubev1.Service) v1.UpstreamList

func (*KubeUpstreamConverter) UpstreamsForService

func (uc *KubeUpstreamConverter) UpstreamsForService(ctx context.Context, svc *kubev1.Service, pods []*kubev1.Pod) v1.UpstreamList

type UpstreamConverter

type UpstreamConverter interface {
	UpstreamsForService(ctx context.Context, svc *kubev1.Service, pods []*kubev1.Pod) v1.UpstreamList
}