Specify auto expiration for redis backend

Author: cschleiden

backend/redis/options.go

@@ -0,0 +1,39 @@
+package redis
+
+import (
+	"time"
+
+	"github.com/cschleiden/go-workflows/backend"
+)
+
+type RedisOptions struct {
+	backend.Options
+
+	BlockTimeout time.Duration
+
+	AutoExpiration time.Duration
+}
+
+type RedisBackendOption func(*RedisOptions)
+
+func WithBlockTimeout(timeout time.Duration) RedisBackendOption {
+	return func(o *RedisOptions) {
+		o.BlockTimeout = timeout
+	}
+}
+
+func WithBackendOptions(opts ...backend.BackendOption) RedisBackendOption {
+	return func(o *RedisOptions) {
+		for _, opt := range opts {
+			opt(&o.Options)
+		}
+	}
+}
+
+// WithAutoExpiration sets the duration after which finished runs will expire from the data store.
+// If set to 0 (default), runs will never expire and need to be manually removed.
+func WithAutoExpiration(expireFinishedRunsAfter time.Duration) RedisBackendOption {
+	return func(o *RedisOptions) {
+		o.AutoExpiration = expireFinishedRunsAfter
+	}
+}

backend/redis/redis.go

@@ -16,28 +16,6 @@ import (
 	"go.opentelemetry.io/otel/trace"
 )
 
-type RedisOptions struct {
-	backend.Options
-
-	BlockTimeout time.Duration
-}
-
-type RedisBackendOption func(*RedisOptions)
-
-func WithBlockTimeout(timeout time.Duration) RedisBackendOption {
-	return func(o *RedisOptions) {
-		o.BlockTimeout = timeout
-	}
-}
-
-func WithBackendOptions(opts ...backend.BackendOption) RedisBackendOption {
-	return func(o *RedisOptions) {
-		for _, opt := range opts {
-			opt(&o.Options)
-		}
-	}
-}
-
 var _ backend.Backend = (*redisBackend)(nil)
 
 func NewRedisBackend(client redis.UniversalClient, opts ...RedisBackendOption) (*redisBackend, error) {