reconcile

Documentation

Index

• func And(fs ...func(core_model.Resource) bool) func(core_model.Resource) bool
• func Any(context.Context, string, dds.Features, model.Resource) bool
• func IsKubernetes(storeType config_store.StoreType) func(core_model.Resource) bool
• func NameHasPrefix(prefix string) func(core_model.Resource) bool
• func NoopResourceMapper(_ dds.Features, r model.Resource) (model.Resource, error)
• func Not(f func(core_model.Resource) bool) func(core_model.Resource) bool
• func ScopeIs(s core_model.ResourceScope) func(core_model.Resource) bool
• func TypeIs(rtype core_model.ResourceType) func(core_model.Resource) bool
• type Reconciler
  • func NewReconciler(hasher envoy_cache.NodeHash, cache envoy_cache.SnapshotCache, ...) Reconciler
• type ResourceFilter
• type ResourceMapper
  • func If(condition func(core_model.Resource) bool, m ResourceMapper) ResourceMapper
• type SnapshotGenerator
  • func NewSnapshotGenerator(resourceManager core_manager.ReadOnlyResourceManager, filter ResourceFilter, ...) SnapshotGenerator

Functions

func And

func And(fs ...func(core_model.Resource) bool) func(core_model.Resource) bool

func Any

func Any(context.Context, string, dds.Features, model.Resource) bool

func IsKubernetes

func IsKubernetes(storeType config_store.StoreType) func(core_model.Resource) bool

func NameHasPrefix

func NameHasPrefix(prefix string) func(core_model.Resource) bool

func NoopResourceMapper

func NoopResourceMapper(_ dds.Features, r model.Resource) (model.Resource, error)

func Not

func Not(f func(core_model.Resource) bool) func(core_model.Resource) bool

func ScopeIs

func ScopeIs(s core_model.ResourceScope) func(core_model.Resource) bool

func TypeIs

func TypeIs(rtype core_model.ResourceType) func(core_model.Resource) bool

Types

type Reconciler

type Reconciler interface {
	// Reconcile reconciles state of node given changed resource types.
	// Returns error and bool which is true if any resource was changed.
	Reconcile(context.Context, *envoy_core.Node, map[model.ResourceType]struct{}, logr.Logger) (error, bool)
	Clear(context.Context, *envoy_core.Node) error
}

Reconciler re-computes configuration for a given node.

func NewReconciler

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

type ResourceFilter

type ResourceFilter func(ctx context.Context, clusterID string, features dds.Features, r core_model.Resource) bool

type ResourceMapper

type ResourceMapper func(features dds.Features, r core_model.Resource) (core_model.Resource, error)

func If

func If(condition func(core_model.Resource) bool, m ResourceMapper) ResourceMapper

type SnapshotGenerator

type SnapshotGenerator interface {
	GenerateSnapshot(context.Context, *envoy_core.Node, cache_dds.SnapshotBuilder, map[model.ResourceType]struct{}) (envoy_cache.ResourceSnapshot, error)
}

Generates a snapshot of xDS resources for a given node.

func NewSnapshotGenerator

func NewSnapshotGenerator(resourceManager core_manager.ReadOnlyResourceManager, filter ResourceFilter, mapper ResourceMapper) SnapshotGenerator