Function NewRedisTaskQueue

pkg/telemetry/exporter/task_queue.go:78–95

NewRedisTaskQueue returns new telemetry task queue.

(
	ctx context.Context, cl *ttnredis.Client, maxLen int64, group string, streamBlockLimit time.Duration,
)

// NewRedisTaskQueue returns new telemetry task queue.
func NewRedisTaskQueue(
	ctx context.Context, cl *ttnredis.Client, maxLen int64, group string, streamBlockLimit time.Duration,
) (TaskQueue, TaskQueueCloser, error) {
	tq := &RedisTaskQueue{
		queue: &ttnredis.TaskQueue{
			Redis:            cl,
			MaxLen:           maxLen,
			Group:            group,
			Key:              cl.Key(telemetryKey),
			StreamBlockLimit: streamBlockLimit,
		},
	}
	if err := tq.Init(ctx); err != nil {
		return nil, nil, err
	}

	return tq, tq.Close, nil
}

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