RedisStateStore

Documentation

Index

• func GetRedisStateStore(redisUri string, password string) (sdk.StateStore, error)
• type Incrementer
• type RedisStateStore
  • func (this *RedisStateStore) Cleanup() error
  • func (this *RedisStateStore) Configure(flowName string, requestId string)
  • func (this *RedisStateStore) CopyStore() (sdk.StateStore, error)
  • func (this *RedisStateStore) Get(key string) (string, error)
  • func (this *RedisStateStore) Incr(key string, value int64) (int64, error)
  • func (this *RedisStateStore) Init() error
  • func (this *RedisStateStore) Set(key string, value string) error
  • func (this *RedisStateStore) Update(key string, oldValue string, newValue string) error

Functions

func GetRedisStateStore

func GetRedisStateStore(redisUri string, password string) (sdk.StateStore, error)

Types

type Incrementer

type Incrementer interface {
	Incr(key string, value int64) (int64, error)
}

Update Compare and Update a valuer

type RedisStateStore

type RedisStateStore struct {
	KeyPath string

	RetryCount int
	// contains filtered or unexported fields
}

func (*RedisStateStore) Cleanup

func (this *RedisStateStore) Cleanup() error

Cleanup (Called only once in a request)

func (*RedisStateStore) Configure

func (this *RedisStateStore) Configure(flowName string, requestId string)

Configure

func (*RedisStateStore) CopyStore

func (this *RedisStateStore) CopyStore() (sdk.StateStore, error)

func (*RedisStateStore) Get

func (this *RedisStateStore) Get(key string) (string, error)

Get Gets a value

func (*RedisStateStore) Incr

func (this *RedisStateStore) Incr(key string, value int64) (int64, error)

Update Compare and Update a valuer

func (*RedisStateStore) Init

func (this *RedisStateStore) Init() error

Init (Called only once in a request)

func (*RedisStateStore) Set

func (this *RedisStateStore) Set(key string, value string) error

Set Sets a value (override existing, or create one)

func (*RedisStateStore) Update

func (this *RedisStateStore) Update(key string, oldValue string, newValue string) error

Update Compare and Update a valuer