backend

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

Variables

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
}