jitter

Documentation

Index

• type DefaultJitterGenerator
  • func NewDefaultGenerator(tfLoader *servicemappingloader.ServiceMappingLoader, ...) *DefaultJitterGenerator
  • func (l *DefaultJitterGenerator) JitteredReenqueue(gvk schema.GroupVersionKind, obj metav1.Object) (time.Duration, error)
  • func (l *DefaultJitterGenerator) WatchJitteredTimeout() time.Duration
• type Generator
• type SimpleJitterGenerator
  • func (*SimpleJitterGenerator) JitteredReenqueue(gvk schema.GroupVersionKind, obj metav1.Object) (time.Duration, error)
  • func (*SimpleJitterGenerator) WatchJitteredTimeout() time.Duration

Types

type DefaultJitterGenerator

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

func NewDefaultGenerator

func NewDefaultGenerator(tfLoader *servicemappingloader.ServiceMappingLoader, dclLoader dclmetadata.ServiceMetadataLoader) *DefaultJitterGenerator

func (*DefaultJitterGenerator) JitteredReenqueue

func (l *DefaultJitterGenerator) JitteredReenqueue(gvk schema.GroupVersionKind, obj metav1.Object) (time.Duration, error)

JitteredReenqueue returns a wait duration to reenqueue the request based on configured reconcile interval in TF servicemapping, DCL metadata, IAM resource config. The wait duration can be overridden with the reconcile interval configured as the object's annotation.

Use JitteredReenqueue whenever we need to reenqueue a reconciliation.

func (*DefaultJitterGenerator) WatchJitteredTimeout

func (l *DefaultJitterGenerator) WatchJitteredTimeout() time.Duration

WatchJitteredTimeout returns a wait duration to reenqueue the request between 1/2 * MeanReconcileReenqueuePeriod and 3/2 * MeanReconcileReenqueuePeriod (not inclusive of upper bound). The mean duration to reenqueue is MeanReconcileReenqueuePeriod.

Use WatchJitteredTimeout whenever we need to wait for a resource to be ready.

type Generator

type Generator interface {
	// WatchJitteredTimeout returns a wait duration to reenqueue the request between
	// 1/2 * MeanReconcileReenqueuePeriod and 3/2 * MeanReconcileReenqueuePeriod (not inclusive of
	// upper bound). The mean duration to reenqueue is MeanReconcileReenqueuePeriod.
	//
	// Use WatchJitteredTimeout whenever we need to wait for a resource to be ready.
	WatchJitteredTimeout() time.Duration

	// JitteredReenqueue returns a wait duration to reenqueue the request based
	// on configured reconcile interval in TF servicemapping, DCL metadata, IAM resource config.
	// The wait duration can be overridden with the reconcile interval configured as the object's annotation.
	//
	// Use JitteredReenqueue whenever we need to reenqueue a reconciliation.
	JitteredReenqueue(gvk schema.GroupVersionKind, obj metav1.Object) (time.Duration, error)
}

type SimpleJitterGenerator

type SimpleJitterGenerator struct {
}

SimpleJitterGenerator does not have any service mapping knowledge.

func (*SimpleJitterGenerator) JitteredReenqueue

func (*SimpleJitterGenerator) JitteredReenqueue(gvk schema.GroupVersionKind, obj metav1.Object) (time.Duration, error)

JitteredReenqueue not implemented as it relies on service mapping knowledge.

func (*SimpleJitterGenerator) WatchJitteredTimeout

func (*SimpleJitterGenerator) WatchJitteredTimeout() time.Duration

WatchJitteredTimeout implements Generator.