reconcilers

Documentation

Index

• func CleanupLogic(ecr *marin3rv1alpha1.EnvoyConfigRevision, xdssCache xdss.Cache, ...)
• func IsInitialized(ecr *marin3rv1alpha1.EnvoyConfigRevision) bool
• func IsStatusReconciled(ecr *marin3rv1alpha1.EnvoyConfigRevision, vt *marin3rv1alpha1.VersionTracker, ...) bool
• type CacheReconciler
  • func NewCacheReconciler(ctx context.Context, logger logr.Logger, client client.Client, ...) CacheReconciler
  • func (r *CacheReconciler) GenerateSnapshot(req types.NamespacedName, resources *marin3rv1alpha1.EnvoyResources) (xdss.Snapshot, error)
  • func (r *CacheReconciler) Reconcile(req types.NamespacedName, resources *marin3rv1alpha1.EnvoyResources, ...) (*marin3rv1alpha1.VersionTracker, error)

Functions

func CleanupLogic

func CleanupLogic(ecr *marin3rv1alpha1.EnvoyConfigRevision, xdssCache xdss.Cache, discoveryStats *stats.Stats, log logr.Logger)

CleanupLogic executes finalization code for EnvoyConfigRevision resources

func IsInitialized

func IsInitialized(ecr *marin3rv1alpha1.EnvoyConfigRevision) bool

IsInitialized checks whether the EnvoyConfigRevision object is initialized or not. Returns true if it has modified the EnvoyConfigRevision. Returns false if it has not.

func IsStatusReconciled

func IsStatusReconciled(ecr *marin3rv1alpha1.EnvoyConfigRevision, vt *marin3rv1alpha1.VersionTracker, xdssCache xdss.Cache, dStats *stats.Stats) bool

IsStatusReconciled calculates the status of the resource

Types

type CacheReconciler

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

func NewCacheReconciler

func NewCacheReconciler(ctx context.Context, logger logr.Logger, client client.Client, xdsCache xdss.Cache,
	decoder envoy_serializer.ResourceUnmarshaller, generator envoy_resources.Generator) CacheReconciler

func (*CacheReconciler) GenerateSnapshot

func (r *CacheReconciler) GenerateSnapshot(req types.NamespacedName, resources *marin3rv1alpha1.EnvoyResources) (xdss.Snapshot, error)

func (*CacheReconciler) Reconcile

func (r *CacheReconciler) Reconcile(req types.NamespacedName, resources *marin3rv1alpha1.EnvoyResources, nodeID, version string) (*marin3rv1alpha1.VersionTracker, error)