Documentation
¶
Index ¶
Constants ¶
View Source
const ( ReasonResync = "resync" ReasonEvent = "event" ResultChanged = "changed" ResultNoChanges = "no_changes" )
Variables ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.