redis

Documentation

Index

• Constants
• func NewBaseDao(conf Config) *baseDao
• func NewRedisMetadataStorage(conf Config) *redisMetadataStorage
• func NewRedisQueue(baseDao *baseDao, shardId string) *redisQueue
• func NewRedisStorage(baseDao *baseDao, encoderDecoder util.EncoderDecoder[model.FlowContext], ...) *redisShardStorage
• type Config

Constants

const ACTION_DEF string = "ACTION"

const WORKFLOW_DEF string = "WORKFLOW"

const WORKFLOW_KEY string = "FLOW"

Functions

func NewBaseDao

func NewBaseDao(conf Config) *baseDao

func NewRedisMetadataStorage

func NewRedisMetadataStorage(conf Config) *redisMetadataStorage

func NewRedisQueue

func NewRedisQueue(baseDao *baseDao, shardId string) *redisQueue

func NewRedisStorage

func NewRedisStorage(baseDao *baseDao, encoderDecoder util.EncoderDecoder[model.FlowContext], shardId string) *redisShardStorage

Types

type Config

type Config struct {
	Addrs     []string
	Namespace string
	PoolSize  int
}