reconcile

Documentation

Index

• func Any(string, kds.Features, model.Resource) bool
• func NoopResourceMapper(r model.Resource) (model.Resource, error)
• type Reconciler
  • func NewReconciler(hasher envoy_cache.NodeHash, cache util_xds_v3.SnapshotCache, ...) Reconciler
• type ResourceFilter
• type ResourceMapper
• type SnapshotGenerator
  • func NewSnapshotGenerator(resourceManager core_manager.ReadOnlyResourceManager, ...) SnapshotGenerator

Functions

func Any

func Any(string, kds.Features, model.Resource) bool

func NoopResourceMapper

func NoopResourceMapper(r model.Resource) (model.Resource, error)

Types

type Reconciler

type Reconciler interface {
	Reconcile(context.Context, *envoy_core.Node) error
	Clear(*envoy_core.Node)
}

Reconciler re-computes configuration for a given node.

func NewReconciler

func NewReconciler(
	hasher envoy_cache.NodeHash,
	cache util_xds_v3.SnapshotCache,
	generator SnapshotGenerator,
	versioner util_xds_v3.SnapshotVersioner,
	mode config_core.CpMode,
	statsCallbacks xds.StatsCallbacks,
) Reconciler

type ResourceFilter

type ResourceFilter func(clusterID string, features kds.Features, r model.Resource) bool

type ResourceMapper

type ResourceMapper func(r model.Resource) (model.Resource, error)

type SnapshotGenerator

type SnapshotGenerator interface {
	GenerateSnapshot(context.Context, *envoy_core.Node) (util_xds_v3.Snapshot, error)
}

Generates a snapshot of xDS resources for a given node.

func NewSnapshotGenerator

func NewSnapshotGenerator(resourceManager core_manager.ReadOnlyResourceManager, types []model.ResourceType, filter ResourceFilter, mapper ResourceMapper) SnapshotGenerator