redisstorage

Documentation

Overview

Package redisstorage is redis storage.

Index

• type Storage
  • func NewStorage(ctx context.Context, opt *redis.Options, prefix string) (*Storage, error)
  • func (st *Storage) Clean(ctx context.Context) error
  • func (st *Storage) Close() error
  • func (st *Storage) Connect(ctx context.Context) error
  • func (st *Storage) Exists(ctx context.Context, key string) (bool, error)
  • func (st *Storage) Get(ctx context.Context, key string) (b []byte, found bool, _ error)
  • func (st *Storage) Set(ctx context.Context, key string, b []byte) error
  • func (st *Storage) ZAddArgs(ctx context.Context, key string, args redis.ZAddArgs) error
  • func (st *Storage) ZRangeArgs(ctx context.Context, z redis.ZRangeArgs, f func(string) (bool, error)) error

Types

type Storage

type Storage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewStorage

func NewStorage(ctx context.Context, opt *redis.Options, prefix string) (*Storage, error)

func (*Storage) Clean

func (st *Storage) Clean(ctx context.Context) error

func (*Storage) Close

func (st *Storage) Close() error

func (*Storage) Connect

func (st *Storage) Connect(ctx context.Context) error

func (*Storage) Exists

func (st *Storage) Exists(ctx context.Context, key string) (bool, error)

func (*Storage) Get

func (st *Storage) Get(ctx context.Context, key string) (b []byte, found bool, _ error)

func (*Storage) Set

func (st *Storage) Set(ctx context.Context, key string, b []byte) error

func (*Storage) ZAddArgs

func (st *Storage) ZAddArgs(ctx context.Context, key string, args redis.ZAddArgs) error

func (*Storage) ZRangeArgs

func (st *Storage) ZRangeArgs(ctx context.Context, z redis.ZRangeArgs, f func(string) (bool, error)) error