redis

Documentation

Index

• Constants
• func NewRedisDelayQueue(config Config, partitionId string) *redisDelayQueue
• func NewRedisFlowDao(conf Config, encoderDecoder util.EncoderDecoder[model.FlowContext], ...) *redisFlowDao
• func NewRedisPartition(config Config, encoderDecoder util.EncoderDecoder[model.FlowContext], ...) *redisPartition
• func NewRedisPartitions(config Config, encoderDecoder util.EncoderDecoder[model.FlowContext], ...) *persistence.Partitions
• func NewRedisQueue(config Config, partitionId string) *redisQueue
• func NewRedisTaskDao(conf Config, encoderDecoder util.EncoderDecoder[model.TaskDef]) *redisTaskDao
• func NewRedisWorkflowDao(conf Config) *redisWorkflowDao
• type Config

Constants

const TASK_KEY = "TASK_DEF"

const WORKFLOW_DEF string = "WORKFLOW"

const WORKFLOW_KEY string = "FLOW"

Functions

func NewRedisDelayQueue

func NewRedisDelayQueue(config Config, partitionId string) *redisDelayQueue

func NewRedisFlowDao

func NewRedisFlowDao(conf Config, encoderDecoder util.EncoderDecoder[model.FlowContext], partId string) *redisFlowDao

func NewRedisPartition

func NewRedisPartition(config Config, encoderDecoder util.EncoderDecoder[model.FlowContext], partId string) *redisPartition

func NewRedisPartitions

func NewRedisPartitions(config Config, encoderDecoder util.EncoderDecoder[model.FlowContext], partitionCount int) *persistence.Partitions

func NewRedisQueue

func NewRedisQueue(config Config, partitionId string) *redisQueue

func NewRedisTaskDao

func NewRedisTaskDao(conf Config, encoderDecoder util.EncoderDecoder[model.TaskDef]) *redisTaskDao

func NewRedisWorkflowDao

func NewRedisWorkflowDao(conf Config) *redisWorkflowDao

Types

type Config

type Config struct {
	Addrs     []string
	Namespace string
}