reconciler

Documentation

Index

• type Key
  • func KeyForObject(obj Object) Key
  • func (k Key) String() string
  • func (k Key) WithNamespace(namespace string) Key
• type NetworkError
  • func (e *NetworkError) Error() string
• type NetworkErrorReconciler
  • func (r *NetworkErrorReconciler) Reconcile(ctx context.Context, key string) error
• type Object
• type Options
  • func (o Options) TrackerResyncPeriod() time.Duration
• type Tracker

Types

type Key

type Key struct {
	GroupKind      schema.GroupKind
	NamespacedName types.NamespacedName
}

func KeyForObject

func KeyForObject(obj Object) Key

func (Key) String

func (k Key) String() string

func (Key) WithNamespace

func (k Key) WithNamespace(namespace string) Key

type NetworkError

type NetworkError struct {
	Err error
}

func (*NetworkError) Error

func (e *NetworkError) Error() string

type NetworkErrorReconciler

type NetworkErrorReconciler struct {
	Reconciler controller.Reconciler
}

func (*NetworkErrorReconciler) Reconcile

func (r *NetworkErrorReconciler) Reconcile(ctx context.Context, key string) error

type Object

type Object interface {
	GetName() string
	GetNamespace() string
	GetObjectKind() schema.ObjectKind
}

type Options

type Options struct {
	Logger *zap.SugaredLogger

	Client                  versioned.Interface
	ResyncPeriod            time.Duration
	SourcePollingFrequency  time.Duration
	BuilderPollingFrequency time.Duration
}

func (Options) TrackerResyncPeriod

func (o Options) TrackerResyncPeriod() time.Duration

type Tracker

type Tracker interface {
	Track(ref Key, obj types.NamespacedName) error
	OnChanged(obj interface{})
}