redis

Jul 12, 2019

Changes in this version

type Database

+ func (db *Database) Cmdable(ctx context.Context) redis.Cmdable

+ func (db *Database) Transaction(ctx context.Context, fn TransactionFn) error

+ type TransactionFn func(ctx context.Context) error

Jun 9, 2019

Changes in this version

type Int64Set

+ func (set *Int64Set) Contains(value int64) (bool, error)

type StringsSet

+ func (set *StringsSet) Contains(value string) (bool, error)

Feb 25, 2019

Changes in this version

+ var ErrDone = errors.New("done")

Jan 1, 2019

Changes in this version

type Hash

+ func (hash *Hash) ExpireAt(key string, t time.Time) error

Jan 1, 2019

Changes in this version

type Hash

+ func (hash *Hash) Delete(key string) error

Jan 1, 2019

Changes in this version

+ func Mask(cols ...string) []string

type Database

+ func (db *Database) Close() error

+ func (db *Database) Hash(name string, model Model) *Hash

+ type Hash struct

+ func (hash *Hash) Get(key string, instance Model, masks ...MaskOpt) error

+ func (hash *Hash) Put(key string, instance Model, masks ...MaskOpt) error

+ type MaskOpt []string

+ type Model interface

+ IsRedisModel func() bool

Dec 29, 2018

Changes in this version

+ var Done = fmt.Errorf("redis: done")

+ var ErrNoSuchEntity = fmt.Errorf("redis: no such entity")

+ type BooleanKV struct

+ func (kv *BooleanKV) Delete() error

+ func (kv *BooleanKV) Exists() (bool, error)

+ func (kv *BooleanKV) Get() (bool, error)

+ func (kv *BooleanKV) Set(value bool) error

+ func (kv *BooleanKV) SetTTL(value bool, ttl time.Duration) error

+ type Counter struct

+ func (c *Counter) Decrement() error

+ func (c *Counter) Get() (int64, error)

+ func (c *Counter) Increment() error

+ func (c *Counter) IncrementBy(value int64) error

+ func (c *Counter) Set(value int64) error

+ type Counters struct

+ func (counters *Counters) Key(key string) *Counter

+ type Database struct

+ func Open(hostname, applicationName string) *Database

+ func (db *Database) BooleanKV(key string) *BooleanKV

+ func (db *Database) Counters(key string) *Counters

+ func (db *Database) DirectClient() *redis.Client

+ func (db *Database) FlushAllKeysFromDatabase() error

+ func (db *Database) Int32KV(key string) *Int32KV

+ func (db *Database) Int64KV(key string) *Int64KV

+ func (db *Database) Int64Set(key string) *Int64Set

+ func (db *Database) ProtoHash(key string) *ProtoHash

+ func (db *Database) ProtoKV(key string) *ProtoKV

+ func (db *Database) ProtoList(key string) *ProtoList

+ func (db *Database) PubSub(name string) *PubSub

+ func (db *Database) StringKV(key string) *StringKV

+ func (db *Database) StringsList(key string) *StringsList

+ func (db *Database) StringsSet(key string) *StringsSet

+ func (db *Database) TimeKV(key string) *TimeKV

+ type Int32KV struct

+ func (kv *Int32KV) Delete() error

+ func (kv *Int32KV) Exists() (bool, error)

+ func (kv *Int32KV) Get() (int32, error)

+ func (kv *Int32KV) Set(value int32) error

+ func (kv *Int32KV) SetTTL(value int32, ttl time.Duration) error

+ type Int64KV struct

+ func (kv *Int64KV) Delete() error

+ func (kv *Int64KV) Exists() (bool, error)

+ func (kv *Int64KV) Get() (int64, error)

+ func (kv *Int64KV) Set(value int64) error

+ func (kv *Int64KV) SetTTL(value int64, ttl time.Duration) error

+ type Int64Set struct

+ func (set *Int64Set) Add(values ...int64) error

+ func (set *Int64Set) Len() (int64, error)

+ func (set *Int64Set) Members() ([]int64, error)

+ func (set *Int64Set) Remove(values ...int64) error

+ type MultiError []error

+ func (merr MultiError) Error() string

+ func (merr MultiError) HasError() bool

+ type ProtoHash struct

+ func (hash *ProtoHash) Delete(key string) error

+ func (hash *ProtoHash) Get(key string, model proto.Message) error

+ func (hash *ProtoHash) GetMulti(keys []string, result interface{}) error

+ func (hash *ProtoHash) PrepareInsert() *ProtoHashInsert

+ type ProtoHashInsert struct

+ func (insert *ProtoHashInsert) Commit() error

+ func (insert *ProtoHashInsert) Set(key string, value proto.Message) error

+ type ProtoKV struct

+ func (kv *ProtoKV) Delete() error

+ func (kv *ProtoKV) Exists() (bool, error)

+ func (kv *ProtoKV) Get(value proto.Message) error

+ func (kv *ProtoKV) Set(value proto.Message) error

+ func (kv *ProtoKV) SetTTL(value proto.Message, ttl time.Duration) error

+ type ProtoList struct

+ func (list *ProtoList) Add(values ...proto.Message) error

+ func (list *ProtoList) GetAll(result interface{}) error

+ func (list *ProtoList) GetRange(start, end int64, result interface{}) error

+ func (list *ProtoList) Len() (int64, error)

+ func (list *ProtoList) Remove(value proto.Message) error

+ type PubSub struct

+ func (pubsub *PubSub) Publish(msg proto.Message) error

+ func (pubsub *PubSub) Subscribe() *PubSubSubscription

+ type PubSubSubscription struct

+ func (sub *PubSubSubscription) Close()

+ func (sub *PubSubSubscription) Next(dest proto.Message) error

+ type StringKV struct

+ func (kv *StringKV) Delete() error

+ func (kv *StringKV) Exists() (bool, error)

+ func (kv *StringKV) Get() (string, error)

+ func (kv *StringKV) Set(value string) error

+ func (kv *StringKV) SetTTL(value string, ttl time.Duration) error

+ type StringsList struct

+ func (list *StringsList) Add(values []string) error

+ func (list *StringsList) GetAll() ([]string, error)

+ func (list *StringsList) GetRange(start, end int64) ([]string, error)

+ func (list *StringsList) Len() (int64, error)

+ func (list *StringsList) Remove(value string) error

+ type StringsSet struct

+ func (set *StringsSet) Add(values ...string) error

+ func (set *StringsSet) Len() (int64, error)

+ func (set *StringsSet) Members() ([]string, error)

+ func (set *StringsSet) Remove(values ...string) error

+ func (set *StringsSet) SortAlpha() ([]string, error)

+ type TimeKV struct

+ func (kv *TimeKV) Delete() error

+ func (kv *TimeKV) Exists() (bool, error)

+ func (kv *TimeKV) Get() (time.Time, error)

+ func (kv *TimeKV) Set(value time.Time) error

+ func (kv *TimeKV) SetTTL(value time.Time, ttl time.Duration) error