Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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.Resource) (xdss.Snapshot, error)
func (*CacheReconciler) Reconcile ¶
func (r *CacheReconciler) Reconcile(ctx context.Context, req types.NamespacedName, resources []marin3rv1alpha1.Resource, nodeID, version string) (*marin3rv1alpha1.VersionTracker, error)
Click to show internal directories.
Click to hide internal directories.