redis

Documentation

Index

• Variables
• type Storage
  • func NewStorage(ctx context.Context, addrs []string, password string, withTLS bool, ...) (*Storage, error)
  • func (stor *Storage) LoadCheckPoints(ctx context.Context) (*stordto.ChCheckPoint, bool, error)
  • func (stor *Storage) RemoveAllData(ctx context.Context) error
  • func (stor *Storage) SaveCheckPoints(ctx context.Context, cp *stordto.ChCheckPoint) (*stordto.ChCheckPoint, error)

Variables

var ErrStorVersionMismatch = errors.New("error version mismatch")

ErrStorVersionMismatch is returned when the version of the checkpoint in the storage

Types

type Storage

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

Storage is a redis storage implementation

func NewStorage

func NewStorage(
	ctx context.Context,
	addrs []string,
	password string,
	withTLS bool,
	rootCAs []string,
	dbPrefix string,
	channelName string,
) (*Storage, error)

NewStorage creates a new redis storage

func (*Storage) LoadCheckPoints

func (stor *Storage) LoadCheckPoints(ctx context.Context) (*stordto.ChCheckPoint, bool, error)

LoadCheckPoints loads the checkpoint from the storage

func (*Storage) RemoveAllData

func (stor *Storage) RemoveAllData(ctx context.Context) error

RemoveAllData removes all data from the storage

func (*Storage) SaveCheckPoints

func (stor *Storage) SaveCheckPoints(ctx context.Context, cp *stordto.ChCheckPoint) (*stordto.ChCheckPoint, error)

SaveCheckPoints saves the checkpoint to the storage