server

Documentation

Index

• func NewKDSServer(srv Server, config kds_config.KdsServerConfig) component.Component
• func NewReconciler(hasher envoy_cache.NodeHash, cache util_xds.SnapshotCache, ...) reconcile.Reconciler
• func NewSnapshotGenerator(rt core_runtime.Runtime, resourceTypes []model.ResourceType, ...) reconcile.SnapshotGenerator
• func NewSyncTracker(log logr.Logger, reconciler reconcile.Reconciler, refresh time.Duration) envoy_xds.Callbacks
• func NewVersioner() util_xds.SnapshotVersioner
• func NewXdsContext(log logr.Logger) (envoy_cache.NodeHash, util_xds.SnapshotCache)
• type Server
  • func NewServer(config envoy_cache.Cache, callbacks envoy_server.Callbacks, log logr.Logger, ...) Server

Functions

func NewKDSServer

func NewKDSServer(srv Server, config kds_config.KdsServerConfig) component.Component

func NewReconciler

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

func NewSnapshotGenerator

func NewSnapshotGenerator(rt core_runtime.Runtime, resourceTypes []model.ResourceType, filter reconcile.ResourceFilter) reconcile.SnapshotGenerator

func NewSyncTracker

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

func NewVersioner

func NewVersioner() util_xds.SnapshotVersioner

func NewXdsContext

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

Types

type Server

type Server interface {
	mesh_proto.KumaDiscoveryServiceServer
}

func NewServer

func NewServer(config envoy_cache.Cache, callbacks envoy_server.Callbacks, log logr.Logger, clusterID string) Server