server

Documentation

Index

• Constants
• func NewNackBackoff(backoff time.Duration) util_xds.DeltaCallbacks
• type ErrorRecorderStream
  • func NewErrorRecorderStream(s stream.DeltaStream) ErrorRecorderStream
• type EventBasedWatchdog
  • func (e *EventBasedWatchdog) Start(stop <-chan struct{})
• type Server
  • func New(log logr.Logger, rt core_runtime.Runtime, providedTypes []model.ResourceType, ...) (Server, error)
  • func NewServer(config envoy_cache.Cache, callbacks envoy_server.Callbacks) Server
• type ServerStream
  • func NewServerStream(stream mesh_proto.DDSSyncService_ZoneToGlobalSyncClient) ServerStream

Constants

const (
	ReasonResync    = "resync"
	ReasonEvent     = "event"
	ResultChanged   = "changed"
	ResultNoChanges = "no_changes"
)

Functions

func NewNackBackoff

func NewNackBackoff(backoff time.Duration) util_xds.DeltaCallbacks

Types

type ErrorRecorderStream

type ErrorRecorderStream interface {
	stream.DeltaStream
	Err() error
}

ErrorRecorderStream is a DeltaStream that records an error We need this because go-control-plane@v0.11.1/pkg/server/delta/v3/server.go:190 swallows an error on Recv()

func NewErrorRecorderStream

func NewErrorRecorderStream(s stream.DeltaStream) ErrorRecorderStream

type EventBasedWatchdog

type EventBasedWatchdog struct {
	Ctx                 context.Context
	Node                *envoy_core.Node
	EventBus            events.EventBus
	Reconciler          reconcile.Reconciler
	ProvidedTypes       map[model.ResourceType]struct{}
	Log                 logr.Logger
	NewFlushTicker      func() *time.Ticker
	NewFullResyncTicker func() *time.Ticker
}

func (*EventBasedWatchdog) Start

func (e *EventBasedWatchdog) Start(stop <-chan struct{})

type Server

type Server interface {
	ZoneToGlobal(stream stream.DeltaStream) error
	mesh_proto.DDSSyncServiceServer
}

func New

func New(
	log logr.Logger,
	rt core_runtime.Runtime,
	providedTypes []model.ResourceType,
	serverID string,
	refresh time.Duration,
	filter reconcile.ResourceFilter,
	mapper reconcile.ResourceMapper,
	nackBackoff time.Duration,
) (Server, error)

func NewServer

func NewServer(config envoy_cache.Cache, callbacks envoy_server.Callbacks) Server

type ServerStream

type ServerStream interface {
	stream.DeltaStream
}

func NewServerStream

func NewServerStream(stream mesh_proto.DDSSyncService_ZoneToGlobalSyncClient) ServerStream

NewServerStream converts client stream to a server's DeltaStream, so it can be used in DeltaStreamHandler