queue

type Options struct {
	// Log is the logger to use for Queue logging.
	Log logr.Logger

	// Client is the etcd client to use for Queue operations.
	Client clientapi.Interface

	// Clock is the clock to use for Queue operations.
	Clock clock.Clock

	// Key is the key to use for Queue operations.
	Key *key.Key

	// SchedulerBuilder is the scheduler builder to use for Queue operations.
	SchedulerBuilder *scheduler.Builder

	// TriggerFn is the trigger function to use for Queue operations.
	TriggerFn api.TriggerFunction

	// ConsumerSink is an optional channel to send informer events to.
	ConsumerSink chan<- *api.InformerEvent

	// Workers is the number of workers to use for processing events in the
	// queue.
	Workers uint32
}

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