redis

Documentation

Index

• func NewRedis(rdb *redis.Client, prefix string) chepun.StateManager
• type Redis
  • func (r *Redis) All(ctx context.Context, correlationId string) (map[string][]byte, error)
  • func (r *Redis) Append(ctx context.Context, correlationId string, correlationConfig []byte, ...) error
  • func (r *Redis) Delete(ctx context.Context, correlationId string) error

Functions

func NewRedis

func NewRedis(rdb *redis.Client, prefix string) chepun.StateManager

Types

type Redis

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

func (*Redis) All

func (r *Redis) All(ctx context.Context, correlationId string) (map[string][]byte, error)

func (*Redis) Append

func (r *Redis) Append(ctx context.Context, correlationId string, correlationConfig []byte, queueName string, message []byte) error

func (*Redis) Delete

func (r *Redis) Delete(ctx context.Context, correlationId string) error