backend

package

v0.0.0-...-894910e Latest Latest Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubernetes/cloud-provider-alibaba-cloud

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func LookupServicePort(svc *corev1.Service, port intstr.IntOrString) (corev1.ServicePort, error)
func NewDefaultEndpointResolver(store store.Storer, k8sClient client.Client, cloud prvd.Provider, ...) *defaultEndpointResolver
type EndpointResolver
type Manager
- func NewBackendManager(store store.Storer, kubeClient client.Client, cloud prvd.Provider, ...) *Manager
- func (mgr *Manager) BuildServicePortSDKBackends(ctx context.Context, svcKey types.NamespacedName, port intstr.IntOrString) ([]alb.BackendItem, bool, error)
- func (mgr *Manager) BuildServicePortsToSDKBackends(ctx context.Context, svc *v1.Service) (map[int32][]alb.BackendItem, bool, error)
type NodePortEndpoint
- func RemoteDuplicatedBackends(backends []NodePortEndpoint) []NodePortEndpoint
type PodEndpoint

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrNotFound = errors.New("backend not found")

Functions ¶

func LookupServicePort ¶

func LookupServicePort(svc *corev1.Service, port intstr.IntOrString) (corev1.ServicePort, error)

func NewDefaultEndpointResolver ¶

func NewDefaultEndpointResolver(store store.Storer, k8sClient client.Client, cloud prvd.Provider, logger logr.Logger) *defaultEndpointResolver

Types ¶

type EndpointResolver ¶

type EndpointResolver interface {
	ResolveENIEndpoints(ctx context.Context, svcKey types.NamespacedName, port intstr.IntOrString) ([]NodePortEndpoint, bool, error)

	ResolveLocalEndpoints(ctx context.Context, svcKey types.NamespacedName, port intstr.IntOrString) ([]NodePortEndpoint, bool, error)

	ResolveClusterEndpoints(ctx context.Context, svcKey types.NamespacedName, port intstr.IntOrString) ([]NodePortEndpoint, bool, error)
}

type Manager ¶

type Manager struct {
	EndpointResolver
	// contains filtered or unexported fields
}

func NewBackendManager ¶

func NewBackendManager(store store.Storer, kubeClient client.Client, cloud prvd.Provider, logger logr.Logger) *Manager

func (*Manager) BuildServicePortSDKBackends ¶

func (mgr *Manager) BuildServicePortSDKBackends(ctx context.Context, svcKey types.NamespacedName, port intstr.IntOrString) ([]alb.BackendItem, bool, error)

func (*Manager) BuildServicePortsToSDKBackends ¶

func (mgr *Manager) BuildServicePortsToSDKBackends(ctx context.Context, svc *v1.Service) (map[int32][]alb.BackendItem, bool, error)

type NodePortEndpoint ¶

type NodePortEndpoint alb.BackendItem

func RemoteDuplicatedBackends ¶

func RemoteDuplicatedBackends(backends []NodePortEndpoint) []NodePortEndpoint

type PodEndpoint ¶

type PodEndpoint struct {
	IP       string
	Port     int
	NodeName *string
	Pod      *corev1.Pod
}

Source Files ¶

View all Source files

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