service

Documentation

Index

• Constants
• func NewReconciler(hasher envoy_cache.NodeHash, cache util_xds_v3.SnapshotCache, ...) mads_reconcile.Reconciler
• func NewReconcilerRestCallbacks(reconciler mads_reconcile.Reconciler) util_xds.RestCallbacks
• func NewService(config *mads.MonitoringAssignmentServerConfig, ...) *service
• func NewSnapshotGenerator(rm core_manager.ReadOnlyResourceManager) util_xds_v3.SnapshotGenerator
• func NewSyncTracker(reconciler mads_reconcile.Reconciler, refresh time.Duration, log logr.Logger) envoy_xds.Callbacks
• func NewVersioner() util_xds_v3.SnapshotVersioner
• func NewXdsContext(log logr.Logger) (envoy_cache.NodeHash, util_xds_v3.SnapshotCache)
• type Server
  • func NewServer(cache envoy_cache.Cache, callbacks envoy_server.Callbacks) Server

Constants

const FetchMonitoringAssignmentsPath = "/v3/discovery:monitoringassignments"

Functions

func NewReconciler

func NewReconciler(hasher envoy_cache.NodeHash, cache util_xds_v3.SnapshotCache,
	generator util_xds_v3.SnapshotGenerator, versioner util_xds_v3.SnapshotVersioner) mads_reconcile.Reconciler

func NewReconcilerRestCallbacks

func NewReconcilerRestCallbacks(reconciler mads_reconcile.Reconciler) util_xds.RestCallbacks

func NewService

func NewService(config *mads.MonitoringAssignmentServerConfig, rm core_manager.ReadOnlyResourceManager, log logr.Logger) *service

func NewSnapshotGenerator

func NewSnapshotGenerator(rm core_manager.ReadOnlyResourceManager) util_xds_v3.SnapshotGenerator

func NewSyncTracker

func NewSyncTracker(reconciler mads_reconcile.Reconciler, refresh time.Duration, log logr.Logger) envoy_xds.Callbacks

func NewVersioner

func NewVersioner() util_xds_v3.SnapshotVersioner

func NewXdsContext

func NewXdsContext(log logr.Logger) (envoy_cache.NodeHash, util_xds_v3.SnapshotCache)

Types

type Server

type Server interface {
	observability_v1.MonitoringAssignmentDiscoveryServiceServer
}

func NewServer

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