telemetry

type CLI struct {
	Enable bool   `name:"enable" description:"Enables telemetry for CLI"`
	Target string `name:"target" description:"Target to which the information will be sent to"`
}

type Config struct {
	Enable               bool                 `name:"enable" description:"Enables telemetry collection"`
	Target               string               `name:"target" description:"Target to which the information will be sent to"`                                 // nolint:lll
	UIDElements          []string             `name:"uid-elements" description:"Elements that will be used to generate the UID"`                            // nolint:lll
	NumConsumers         uint64               `name:"num-consumers" description:"Number of consumers that will be used to monitor telemetry related tasks"` // nolint:lll
	EntityCountTelemetry EntityCountTelemetry `name:"entity-count-telemetry"`
}

type EntityCountTelemetry struct {
	Enable   bool          `name:"enable" description:"Enables entity count collection"`
	Interval time.Duration `name:"interval" description:"Interval between each run of the collection"`
}

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

type TaskCallback func(context.Context) (time.Time, error)

type TaskQueue interface {
	// Add telemetry task identified by `id` at time t.
	// Implementations must ensure that Add returns fast.
	Add(ctx context.Context, id string, t time.Time, replace bool) error

	// RegisterCallback registers a callback that is called when a task is popped.
	// All callbacks should be registered before the dispatch of the tasks in the queue, otherwise they are proned to
	// fail within the first pop call.
	RegisterCallback(callbackID string, callback TaskCallback)

	// Dispatch the tasks in the queue.
	Dispatch(ctx context.Context, consumerID string) error

	// Pop pops the most recent task in the schedule, for which timestamp is in range [0, time.Now()], the value of
	// the queue goes through the registered callback and determines which one should be called.
	Pop(ctx context.Context, consumerID string) error
}

type TaskQueueCloser func(context.Context) error