state

Documentation

Index

• Constants
• func New(opts ServiceStateSubscriberOpts) *serviceStateSubscriber
• func NewClusterServiceStateCache(opts ClusterServiceStateOpts) *clusterServiceStateCache
• func NewServiceContainer(svc *v1.Service) *serviceContainer
• func NewServiceOpts(svc *v1.Service) *serviceOpts
• type ClusterServiceStateOpts
• type EndpointSliceOperationStatus
  • func (eos EndpointSliceOperationStatus) String() string
• type ServiceStateSubscriber
• type ServiceStateSubscriberOpts

Constants

const (
	ENDPOINTSLICE_OPERATION_STATUS_NOOP = iota
	ENDPOINTSLICE_OPERATION_STATUS_UPDATED
	ENDPOINTSLICE_OPERATION_STATUS_DELETED
	ENDPOINTSLICE_OPERATION_STATUS_INVALID_SERVICE_LABEL
	ENDPOINTSLICE_OPERATION_STATUS_ERROR
)

Functions

func New

func New(opts ServiceStateSubscriberOpts) *serviceStateSubscriber

func NewClusterServiceStateCache

func NewClusterServiceStateCache(opts ClusterServiceStateOpts) *clusterServiceStateCache

func NewServiceContainer

func NewServiceContainer(svc *v1.Service) *serviceContainer

NewServiceContainer creates a new service container.

func NewServiceOpts

func NewServiceOpts(svc *v1.Service) *serviceOpts

NewServiceOpts parses options coming from svc annotations.

Types

type ClusterServiceStateOpts

type ClusterServiceStateOpts struct {
	Log logr.Logger
}

type EndpointSliceOperationStatus

type EndpointSliceOperationStatus int

func (EndpointSliceOperationStatus) String

func (eos EndpointSliceOperationStatus) String() string

type ServiceStateSubscriber

type ServiceStateSubscriber interface {
	proxyconfig.EndpointSliceHandler
	proxyconfig.ServiceHandler

	ReceiveEvent(ctx context.Context) *snapshot.Snapshot
	Snapshot() *snapshot.Snapshot
}

type ServiceStateSubscriberOpts

type ServiceStateSubscriberOpts struct {
	Log logger.Logger
}