Method Init

pkg/telemetry/exporter/task_queue.go:98–100

Init initializes the TelemetryTaskQueue.

(ctx context.Context)

// Init initializes the TelemetryTaskQueue.
func (q *RedisTaskQueue) Init(ctx context.Context) error {
	return q.queue.Init(ctx)
}

// Close closes the TelemetryTaskQueue.
func (q *RedisTaskQueue) Close(ctx context.Context) error {