redis

Documentation

Index

• type Accessor
  • func New(connectURL string) (*Accessor, error)
  • func (acc *Accessor) Begin() (kvstorage.KeyValueTxAccessor, error)
  • func (acc *Accessor) Commit() (err error)
  • func (acc *Accessor) Del(key ...string) error
  • func (acc *Accessor) Get(key string) (any, error)
  • func (acc *Accessor) Incr(key string) (int64, error)
  • func (acc *Accessor) Keys(pattern string) ([]string, error)
  • func (acc *Accessor) MGet(keys ...string) ([]any, error)
  • func (acc *Accessor) MSet(vals ...any) error
  • func (acc *Accessor) Set(key string, value any, expiration ...time.Duration) error

Types

type Accessor

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

Accessor implementation of the redis key value accessor

func New

func New(connectURL string) (*Accessor, error)

New driver connection

func (*Accessor) Begin

func (acc *Accessor) Begin() (kvstorage.KeyValueTxAccessor, error)

Begin new transaction

func (*Accessor) Commit

func (acc *Accessor) Commit() (err error)

Commit transaction changes

func (*Accessor) Del

func (acc *Accessor) Del(key ...string) error

Del keys from the storage

func (*Accessor) Get

func (acc *Accessor) Get(key string) (any, error)

Get value from key

func (*Accessor) Incr

func (acc *Accessor) Incr(key string) (int64, error)

Incr value with key

func (*Accessor) Keys

func (acc *Accessor) Keys(pattern string) ([]string, error)

Keys returns the list of keys with pattern "text"+*

func (*Accessor) MGet

func (acc *Accessor) MGet(keys ...string) ([]any, error)

MGet returns values from banch of keys in the same order

func (*Accessor) MSet

func (acc *Accessor) MSet(vals ...any) error

MSet multiple set operation with {Key, Value, ...} input

func (*Accessor) Set

func (acc *Accessor) Set(key string, value any, expiration ...time.Duration) error

Set value for the key