Versions in this module Expand all Collapse all v0 v0.0.1 Nov 4, 2025 Changes in this version + var ErrDataExist = errors.New("Data already exist") + var ErrLocked = errors.New("Another client has locked") + var ErrNil = redis.ErrNil + type FieldEntry struct + Key string + Value []byte + func FieldEntries(replay interface{}, err error) ([]FieldEntry, error) + type MessageEntry struct + Fields []FieldEntry + ID string + func MessageEntries(reply interface{}, err error) ([]MessageEntry, error) + type RediStore struct + Pool *redis.Pool + func NewRediStore(size int, network, address, password string) (*RediStore, error) + func NewRediStoreWithDB(size int, network, address, password, DB string) (*RediStore, error) + func NewRediStoreWithPool(pool *redis.Pool) (*RediStore, error) + func NewRediStoreWithURL(ctx context.Context, size int, rawurl string, options ...redis.DialOption) (*RediStore, error) + func (s *RediStore) Close() error + func (s *RediStore) Delete(key string) error + func (s *RediStore) Do(cmd string, args ...interface{}) (interface{}, error) + func (s *RediStore) Get(key string) (interface{}, error) + func (s *RediStore) Lock(key, owner string, age time.Duration) error + func (s *RediStore) Put(key string, val interface{}, age time.Duration) error + func (s *RediStore) PutJSON(key string, val interface{}, age time.Duration) error + func (s *RediStore) ScanJSON(key string, val interface{}) error + func (s *RediStore) ScanKey(cursor int64, pattern string, limit int) (int64, [][]byte, error) + func (s *RediStore) TryLock(key, owner string, age time.Duration) error + func (s *RediStore) Unlock(key, owner string) error + func (s *RediStore) XACK(streamName, groupName, entryId string) (int, error) + func (s *RediStore) XAdd(streamName string, key string, val interface{}, kv ...interface{}) (string, error) + func (s *RediStore) XClaim(streamName, groupName, entryId, toConsumerName string, ...) error + func (s *RediStore) XCreateGroup(streamName, groupName string) error + func (s *RediStore) XDel(streamName, msgId string, otherIds ...interface{}) (int, error) + func (s *RediStore) XDeleteGroupUser(streamName, groupName, consumerName string) error + func (s *RediStore) XDestroyGroup(streamName, groupName string) error + func (s *RediStore) XLen(streamName string) (int, error) + func (s *RediStore) XPending(streamName, groupName string, limit int64) ([]interface{}, error) + func (s *RediStore) XReadGroup(streamName, groupName, consumerName string, limit int, timeout time.Duration) ([]StreamEntry, error) + func (s *RediStore) XTrim(streamName string, maxLen int) (int, error) + type StreamEntry struct + Messages []MessageEntry + StreamName string + func StreamEntries(reply interface{}, err error) ([]StreamEntry, error)
Go to main page