redis

Documentation

Index

• type Option
  • func WithLockTTL(ttl time.Duration) Option
  • func WithPrefix(prefix string) Option
  • func WithTTL(ttl time.Duration) Option
• type RedisStorage
  • func NewRedisStorage(client *redis.Client, opts ...Option) *RedisStorage
  • func (r *RedisStorage) GetState(ctx context.Context, entityID string) (string, error)
  • func (r *RedisStorage) Lock(ctx context.Context, entityID string) (func(), error)
  • func (r *RedisStorage) SetState(ctx context.Context, entityID, state string) error

Types

type Option

type Option func(*RedisStorage)

func WithLockTTL

func WithLockTTL(ttl time.Duration) Option

func WithPrefix

func WithPrefix(prefix string) Option

func WithTTL

func WithTTL(ttl time.Duration) Option

type RedisStorage

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

func NewRedisStorage

func NewRedisStorage(client *redis.Client, opts ...Option) *RedisStorage

func (*RedisStorage) GetState

func (r *RedisStorage) GetState(ctx context.Context, entityID string) (string, error)

func (*RedisStorage) Lock

func (r *RedisStorage) Lock(ctx context.Context, entityID string) (func(), error)

func (*RedisStorage) SetState

func (r *RedisStorage) SetState(ctx context.Context, entityID, state string) error