reconciler

type Bucket interface {
	// Name returns a string representing this bucket, which uniquely
	// identifies the bucket and is suitable for use as a resource lock name.
	Name() string

	// Has determines whether this Bucket contains a particular key.
	Has(key types.NamespacedName) bool
}

type ConfigStore interface {
	// ConfigStore is used to attach the frozen configuration to the context.
	ToContext(ctx context.Context) context.Context
}

type Event error

type LeaderAware interface {
	// Promote is called when we become the leader of a given Bucket.  It must be
	// supplied with an enqueue function through which a Bucket resync may be triggered.
	Promote(b Bucket, enq func(Bucket, types.NamespacedName)) error

	// Demote is called when we stop being the leader for the specified Bucket.
	Demote(Bucket)
}

type LeaderAwareFuncs struct {
	sync.RWMutex

	PromoteFunc func(b Bucket, enq func(Bucket, types.NamespacedName)) error
	DemoteFunc  func(b Bucket)
	// contains filtered or unexported fields
}

type OnDeletionInterface interface {
	// ObserveDeletion implements custom logic to observe deletion of the respective resource
	// with the given key.
	ObserveDeletion(ctx context.Context, key types.NamespacedName) error
}

type ReconcilerEvent struct {
	EventType string
	Reason    string
	Format    string
	Args      []interface{}
}