From 49317f48400a9997e6398c6d4f4eff1b32906176 Mon Sep 17 00:00:00 2001
From: Adriano Caloiaro <me@adriano.fyi>
Date: Wed, 12 Jul 2023 12:57:43 -0600
Subject: [PATCH] Make [rR]edisBackend public

---
 backends/redis/redis_backend.go | 33 +++++++++++++++++----------------
 1 file changed, 17 insertions(+), 16 deletions(-)

diff --git a/backends/redis/redis_backend.go b/backends/redis/redis_backend.go
index 253ec78..ed42f79 100644
--- a/backends/redis/redis_backend.go
+++ b/backends/redis/redis_backend.go
@@ -29,8 +29,9 @@ var (
 	ErrInvalidAddr = errors.New("invalid connecton string: see documentation for valid connection strings")
 )
 
-// redisBackend is a Redis-backed neoq backend
-type redisBackend struct {
+// RedisBackend is a Redis-backed neoq backend
+// nolint: revive
+type RedisBackend struct {
 	types.Backend
 	client       *asynq.Client
 	server       *asynq.Server
@@ -38,18 +39,18 @@ type redisBackend struct {
 	config       *config.Config
 	logger       logging.Logger
 	mu           *sync.Mutex // mutext to protect mutating backend state
-	taskProvider *MemoryTaskConfigProvider
+	taskProvider *memoryTaskConfigProvider
 	mgr          *asynq.PeriodicTaskManager
 }
 
-type MemoryTaskConfigProvider struct {
+type memoryTaskConfigProvider struct {
 	mu      *sync.Mutex
 	configs []*asynq.PeriodicTaskConfig
 }
 
-// NewMemoryTaskConfigProvider returns a new asynq MemoryTaskConfigProvider
-func NewMemoryTaskConfigProvider() (p *MemoryTaskConfigProvider) {
-	p = &MemoryTaskConfigProvider{
+// newMemoryTaskConfigProvider returns a new asynq MemoryTaskConfigProvider
+func newMemoryTaskConfigProvider() (p *memoryTaskConfigProvider) {
+	p = &memoryTaskConfigProvider{
 		mu:      &sync.Mutex{},
 		configs: []*asynq.PeriodicTaskConfig{},
 	}
@@ -57,7 +58,7 @@ func NewMemoryTaskConfigProvider() (p *MemoryTaskConfigProvider) {
 }
 
 // GetConfigs returns this provider's periodic task configurations
-func (m *MemoryTaskConfigProvider) GetConfigs() (c []*asynq.PeriodicTaskConfig, err error) {
+func (m *memoryTaskConfigProvider) GetConfigs() (c []*asynq.PeriodicTaskConfig, err error) {
 	m.mu.Lock()
 	cfgs := m.configs
 	m.mu.Unlock()
@@ -65,7 +66,7 @@ func (m *MemoryTaskConfigProvider) GetConfigs() (c []*asynq.PeriodicTaskConfig,
 }
 
 // addConfig adds a periodic task configuration to this provider's configs
-func (m *MemoryTaskConfigProvider) addConfig(taskConfig *asynq.PeriodicTaskConfig) {
+func (m *memoryTaskConfigProvider) addConfig(taskConfig *asynq.PeriodicTaskConfig) {
 	m.mu.Lock()
 	m.configs = append(m.configs, taskConfig)
 	m.mu.Unlock()
@@ -73,10 +74,10 @@ func (m *MemoryTaskConfigProvider) addConfig(taskConfig *asynq.PeriodicTaskConfi
 
 // Backend is a [config.BackendInitializer] that initializes a new Redis-backed neoq backend
 func Backend(ctx context.Context, opts ...config.Option) (backend types.Backend, err error) {
-	b := &redisBackend{
+	b := &RedisBackend{
 		config:       config.New(),
 		mu:           &sync.Mutex{},
-		taskProvider: NewMemoryTaskConfigProvider(),
+		taskProvider: newMemoryTaskConfigProvider(),
 	}
 
 	for _, opt := range opts {
@@ -176,7 +177,7 @@ func WithShutdownTimeout(timeout time.Duration) config.Option {
 }
 
 // Enqueue queues jobs to be executed asynchronously
-func (b *redisBackend) Enqueue(ctx context.Context, job *jobs.Job) (jobID string, err error) {
+func (b *RedisBackend) Enqueue(ctx context.Context, job *jobs.Job) (jobID string, err error) {
 	if job.Queue == "" {
 		err = jobs.ErrNoQueueSpecified
 		return
@@ -207,7 +208,7 @@ func (b *redisBackend) Enqueue(ctx context.Context, job *jobs.Job) (jobID string
 }
 
 // Start starts processing jobs with the specified queue and handler
-func (b *redisBackend) Start(_ context.Context, queue string, h handler.Handler) (err error) {
+func (b *RedisBackend) Start(_ context.Context, queue string, h handler.Handler) (err error) {
 	b.mux.HandleFunc(queue, func(ctx context.Context, t *asynq.Task) (err error) {
 		var p map[string]any
 		if err = json.Unmarshal(t.Payload(), &p); err != nil {
@@ -235,7 +236,7 @@ func (b *redisBackend) Start(_ context.Context, queue string, h handler.Handler)
 // StartCron starts processing jobs with the specified cron schedule and handler
 //
 // See: https://pkg.go.dev/github.com/robfig/cron?#hdr-CRON_Expression_Format for details on the cron spec format
-func (b *redisBackend) StartCron(ctx context.Context, cronSpec string, h handler.Handler) (err error) {
+func (b *RedisBackend) StartCron(ctx context.Context, cronSpec string, h handler.Handler) (err error) {
 	cd, err := crondescriptor.NewCronDescriptor(cronSpec)
 	if err != nil {
 		return fmt.Errorf("error creating cron descriptor: %w", err)
@@ -297,12 +298,12 @@ func toAsynqCronspec(cronSpec string) string {
 }
 
 // SetLogger sets this backend's logger
-func (b *redisBackend) SetLogger(logger logging.Logger) {
+func (b *RedisBackend) SetLogger(logger logging.Logger) {
 	b.logger = logger
 }
 
 // Shutdown halts the worker
-func (b *redisBackend) Shutdown(ctx context.Context) {
+func (b *RedisBackend) Shutdown(ctx context.Context) {
 	b.client.Close()
 	b.server.Shutdown()
 }