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")

Types

type Storage

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

func NewStorage

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

func (*Storage) LoadCheckPoints

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

func (*Storage) RemoveAllData

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

func (*Storage) SaveCheckPoints

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