exposition

Documentation

Overview

Package exposition implements the reflection logic for services and endpointslices.

Index

• Constants
• func NewEndpointSliceReflector(ipamclient ipam.IpamClient, workers uint) manager.Reflector
• func NewNamespacedEndpointSliceReflector(ipamclient ipam.IpamClient) func(*options.ReflectorOpts) manager.NamespacedReflector
• func NewNamespacedServiceReflector(opts *options.ReflectorOpts) manager.NamespacedReflector
• func NewServiceReflector(workers uint) manager.Reflector
• type NamespacedEndpointSliceReflector
  • func (ner *NamespacedEndpointSliceReflector) Handle(ctx context.Context, name string) error
  • func (ner *NamespacedEndpointSliceReflector) MapEndpointIPs(ctx context.Context, endpointslice string, originals []string) ([]string, error)
  • func (ner *NamespacedEndpointSliceReflector) UnmapEndpointIPs(ctx context.Context, endpointslice string) error
• type NamespacedServiceReflector
  • func (nsr *NamespacedServiceReflector) Handle(ctx context.Context, name string) error

Constants

const (
	// EndpointSliceReflectorName -> The name associated with the EndpointSlice reflector.
	EndpointSliceReflectorName = "EndpointSlice"
)

const (
	// ServiceReflectorName -> The name associated with the Service reflector.
	ServiceReflectorName = "Service"
)

Functions

func NewEndpointSliceReflector

func NewEndpointSliceReflector(ipamclient ipam.IpamClient, workers uint) manager.Reflector

NewEndpointSliceReflector returns a new EndpointSliceReflector instance.

func NewNamespacedEndpointSliceReflector

func NewNamespacedEndpointSliceReflector(ipamclient ipam.IpamClient) func(*options.ReflectorOpts) manager.NamespacedReflector

NewNamespacedEndpointSliceReflector returns a function generating NamespacedEndpointSliceReflector instances.

func NewNamespacedServiceReflector

func NewNamespacedServiceReflector(opts *options.ReflectorOpts) manager.NamespacedReflector

NewNamespacedServiceReflector returns a new NamespacedServiceReflector instance.

func NewServiceReflector

func NewServiceReflector(workers uint) manager.Reflector

NewServiceReflector returns a new ServiceReflector instance.

Types

type NamespacedEndpointSliceReflector

type NamespacedEndpointSliceReflector struct {
	generic.NamespacedReflector
	// contains filtered or unexported fields
}

NamespacedEndpointSliceReflector manages the EndpointSlice reflection for a given pair of local and remote namespaces.

func (*NamespacedEndpointSliceReflector) Handle

func (ner *NamespacedEndpointSliceReflector) Handle(ctx context.Context, name string) error

Handle reconciles endpointslice objects.

func (*NamespacedEndpointSliceReflector) MapEndpointIPs

func (ner *NamespacedEndpointSliceReflector) MapEndpointIPs(ctx context.Context, endpointslice string, originals []string) ([]string, error)

MapEndpointIPs maps the local set of addresses to the corresponding remote ones.

func (*NamespacedEndpointSliceReflector) UnmapEndpointIPs

func (ner *NamespacedEndpointSliceReflector) UnmapEndpointIPs(ctx context.Context, endpointslice string) error

UnmapEndpointIPs unmaps the local set of addresses for the given endpointslice and releases the corresponding remote ones.

type NamespacedServiceReflector

type NamespacedServiceReflector struct {
	generic.NamespacedReflector
	// contains filtered or unexported fields
}

NamespacedServiceReflector manages the Service reflection for a given pair of local and remote namespaces.

func (*NamespacedServiceReflector) Handle

func (nsr *NamespacedServiceReflector) Handle(ctx context.Context, name string) error

Handle reconciles service objects.