RedisStateStore

package
v0.0.0-...-b5371e1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 18, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL