kubernetes

package
v1.16.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 14, 2024 License: Apache-2.0 Imports: 37 Imported by: 1

Documentation

Index

Constants

View Source
const (
	ExtensionName = "kubernetes"
)

Variables

This section is empty.

Functions

func NewPlugin

func NewPlugin(kube kubernetes.Interface, kubeCoreCache corecache.KubeCoreCache) plugins.Plugin

func UpdateUpstream

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

func UpstreamName

func UpstreamName(serviceNamespace, serviceName string, servicePort int32) string

Types

type Epkey added in v1.9.25

type Epkey struct {
	Address     string
	Port        uint32
	Name        string
	Namespace   string
	UpstreamRef *core.ResourceRef
	// While we can use the upstream ref to get the upstream and service, if there are too many upstreams that could be slow.
	IsHeadless bool
}

type KubePluginListers

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

func (*KubePluginListers) EndpointsLister

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

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(ns string) kubelisters.EndpointsLister
	Subscribe() <-chan struct{}
	Unsubscribe(<-chan struct{})
}

type KubeUpstreamConverter

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

func DefaultUpstreamConverter

func DefaultUpstreamConverter() *KubeUpstreamConverter

func (*KubeUpstreamConverter) CreateUpstream added in v1.0.0

func (uc *KubeUpstreamConverter) CreateUpstream(ctx context.Context, svc *kubev1.Service, port kubev1.ServicePort) *v1.Upstream

func (*KubeUpstreamConverter) UpstreamsForService

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

type UpstreamConverter

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

Directories

Path Synopsis
Package mock_kubernetes is a generated GoMock package.
Package mock_kubernetes is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL