Documentation ¶
Index ¶
- Variables
- type Client
- func (client *Client) Close() error
- func (client *Client) Delete(key storage.Key) error
- func (client *Client) FlushDB() error
- func (client *Client) Get(key storage.Key) (storage.Value, error)
- func (client *Client) GetAll(keys storage.Keys) (storage.Values, error)
- func (client *Client) Iterate(opts storage.IterateOptions, fn func(it storage.Iterator) error) error
- func (client *Client) List(first storage.Key, limit int) (storage.Keys, error)
- func (client *Client) Put(key storage.Key, value storage.Value) error
- type Queue
Constants ¶
This section is empty.
Variables ¶
var ( // Error is a redis error Error = errs.Class("redis error") )
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is the entrypoint into Redis
func NewClient ¶
NewClient returns a configured Client instance, verifying a successful connection to redis
func NewClientFrom ¶
NewClientFrom returns a configured Client instance from a redis address, verifying a successful connection to redis
func (*Client) Get ¶
Get looks up the provided key from redis returning either an error or the result.
func (*Client) GetAll ¶
GetAll is the bulk method for gets from the redis data store. The maximum keys returned will be storage.LookupLimit. If more than that is requested, an error will be returned
func (*Client) Iterate ¶
func (client *Client) Iterate(opts storage.IterateOptions, fn func(it storage.Iterator) error) error
Iterate iterates over items based on opts
type Queue ¶
type Queue Client
Queue is the aliased entrypoint into Redis
func NewQueue ¶
NewQueue returns a configured Client instance, verifying a successful connection to redis
func NewQueueFrom ¶
NewQueueFrom returns a configured Client instance from a redis address, verifying a successful connection to redis
Directories ¶
Path | Synopsis |
---|---|
Package redisserver is package for starting a redis test server
|
Package redisserver is package for starting a redis test server |