server

Documentation

Overview

Package server provides an implementation of a streaming xDS server.

Index

• func DefaultDataplaneSyncTracker(rt core_runtime.Runtime, reconciler, ingressReconciler SnapshotReconciler, ...) (envoy_xds.Callbacks, error)
• func NewServer(config envoy_cache.Cache, callbacks gcp_server.Callbacks) gcp_server.Server
• func SetupDiagnosticsServer(rt core_runtime.Runtime) error
• func SetupServer(rt core_runtime.Runtime) error
• type DataplaneInsightSink
  • func NewDataplaneInsightSink(accessor SubscriptionStatusAccessor, newTicker func() *time.Ticker, ...) DataplaneInsightSink
• type DataplaneInsightSinkFactoryFunc
• type DataplaneInsightStore
  • func NewDataplaneInsightStore(resManager manager.ResourceManager) DataplaneInsightStore
• type DataplaneMetadataTracker
  • func NewDataplaneMetadataTracker() *DataplaneMetadataTracker
  • func (d *DataplaneMetadataTracker) Metadata(streamId int64) *xds.DataplaneMetadata
  • func (d *DataplaneMetadataTracker) OnFetchRequest(context.Context, *envoy.DiscoveryRequest) error
  • func (d *DataplaneMetadataTracker) OnFetchResponse(*envoy.DiscoveryRequest, *envoy.DiscoveryResponse)
  • func (d *DataplaneMetadataTracker) OnStreamClosed(stream int64)
  • func (d *DataplaneMetadataTracker) OnStreamOpen(context.Context, int64, string) error
  • func (d *DataplaneMetadataTracker) OnStreamRequest(stream int64, req *envoy.DiscoveryRequest) error
  • func (d *DataplaneMetadataTracker) OnStreamResponse(int64, *envoy.DiscoveryRequest, *envoy.DiscoveryResponse)
• type DataplaneStatusTracker
  • func DefaultDataplaneStatusTracker(rt core_runtime.Runtime) DataplaneStatusTracker
  • func NewDataplaneStatusTracker(runtimeInfo core_runtime.RuntimeInfo, ...) DataplaneStatusTracker
• type SnapshotReconciler
  • func DefaultIngressReconciler(rt core_runtime.Runtime) SnapshotReconciler
  • func DefaultReconciler(rt core_runtime.Runtime) SnapshotReconciler
• type SubscriptionStatusAccessor

Functions

func DefaultDataplaneSyncTracker

func DefaultDataplaneSyncTracker(rt core_runtime.Runtime, reconciler, ingressReconciler SnapshotReconciler, metadataTracker *DataplaneMetadataTracker) (envoy_xds.Callbacks, error)

func NewServer

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

NewServer creates handlers from a config watcher and callbacks.

func SetupDiagnosticsServer

func SetupDiagnosticsServer(rt core_runtime.Runtime) error

func SetupServer

func SetupServer(rt core_runtime.Runtime) error

Types

type DataplaneInsightSink

type DataplaneInsightSink interface {
	Start(stop <-chan struct{})
}

func NewDataplaneInsightSink

func NewDataplaneInsightSink(
	accessor SubscriptionStatusAccessor,
	newTicker func() *time.Ticker,
	store DataplaneInsightStore) DataplaneInsightSink

type DataplaneInsightSinkFactoryFunc

type DataplaneInsightSinkFactoryFunc = func(SubscriptionStatusAccessor) DataplaneInsightSink

type DataplaneInsightStore

type DataplaneInsightStore interface {
	Upsert(dataplaneId core_model.ResourceKey, subscription *mesh_proto.DiscoverySubscription) error
}

func NewDataplaneInsightStore

func NewDataplaneInsightStore(resManager manager.ResourceManager) DataplaneInsightStore

type DataplaneMetadataTracker

type DataplaneMetadataTracker struct {
	// contains filtered or unexported fields
}

func NewDataplaneMetadataTracker

func NewDataplaneMetadataTracker() *DataplaneMetadataTracker

func (*DataplaneMetadataTracker) Metadata

func (d *DataplaneMetadataTracker) Metadata(streamId int64) *xds.DataplaneMetadata

func (*DataplaneMetadataTracker) OnFetchRequest

func (d *DataplaneMetadataTracker) OnFetchRequest(context.Context, *envoy.DiscoveryRequest) error

func (*DataplaneMetadataTracker) OnFetchResponse

func (d *DataplaneMetadataTracker) OnFetchResponse(*envoy.DiscoveryRequest, *envoy.DiscoveryResponse)

func (*DataplaneMetadataTracker) OnStreamClosed

func (d *DataplaneMetadataTracker) OnStreamClosed(stream int64)

func (*DataplaneMetadataTracker) OnStreamOpen

func (d *DataplaneMetadataTracker) OnStreamOpen(context.Context, int64, string) error

func (*DataplaneMetadataTracker) OnStreamRequest

func (d *DataplaneMetadataTracker) OnStreamRequest(stream int64, req *envoy.DiscoveryRequest) error

func (*DataplaneMetadataTracker) OnStreamResponse

func (d *DataplaneMetadataTracker) OnStreamResponse(int64, *envoy.DiscoveryRequest, *envoy.DiscoveryResponse)

type DataplaneStatusTracker

type DataplaneStatusTracker interface {
	envoy_xds.Callbacks
	GetStatusAccessor(streamID int64) (SubscriptionStatusAccessor, bool)
}

func DefaultDataplaneStatusTracker

func DefaultDataplaneStatusTracker(rt core_runtime.Runtime) DataplaneStatusTracker

func NewDataplaneStatusTracker

func NewDataplaneStatusTracker(runtimeInfo core_runtime.RuntimeInfo,
	createStatusSink DataplaneInsightSinkFactoryFunc) DataplaneStatusTracker

type SnapshotReconciler

type SnapshotReconciler interface {
	Reconcile(ctx xds_context.Context, proxy *model.Proxy) error
	Clear(proxyId *model.ProxyId) error
}

func DefaultIngressReconciler

func DefaultIngressReconciler(rt core_runtime.Runtime) SnapshotReconciler

func DefaultReconciler

func DefaultReconciler(rt core_runtime.Runtime) SnapshotReconciler

type SubscriptionStatusAccessor

type SubscriptionStatusAccessor interface {
	GetStatus() (core_model.ResourceKey, *mesh_proto.DiscoverySubscription)
}