structure

Aug 14, 2023

Changes in this version

type SetStructure

+ func (s *SetStructure) SDel(key string) error

Aug 13, 2023

Changes in this version

+ type DecodedList struct

+ Expiration int64

+ List *list

+ type ExpiredItem struct

+ Data []byte

+ Expiration int64

+ type FSetWithTTL struct

+ TTL int64

+ ZSet *FSets

type HashStructure

+ func (hs *HashStructure) HDelAll(k string) (bool, error)

+ func (hs *HashStructure) HExpire(k string, ttl int64) (bool, error)

type ListStructure

+ func (l *ListStructure) Size(key string) (string, error)

+ func (l *ListStructure) TTL(k string) (int64, error)

type SetStructure

+ func (s *SetStructure) Size(key string) (string, error)

+ func (s *SetStructure) TTL(k string) (int64, error)

Aug 9, 2023

Changes in this version

type HashStructure

+ HashFieldType string

+ func (hs *HashStructure) GetFields(k string) []string

+ func (hs *HashStructure) HGetAllFieldAndValue(k string) (map[string]interface{}, error)

Aug 8, 2023

Changes in this version

type HashStructure

+ func (hs *HashStructure) Size(k string, f ...interface{}) (string, error)

+ func (hs *HashStructure) TTL(k string) (int64, error)

type StringStructure

+ func (s *StringStructure) Size(key string) (string, error)

+ func (s *StringStructure) TTL(key string) (int64, error)

Aug 1, 2023

Changes in this version

+ type ExpireStructure struct

+ func NewExpireStructure(options config.Options) (*ExpireStructure, error)

+ func (ek *ExpireStructure) EXPIRE(key string, seconds int64) error

+ func (ek *ExpireStructure) EXPIREAT(key string, timestamp int64) error

+ func (ek *ExpireStructure) EXPIREBY(key string, duration int64, tag ...string) error

+ func (ek *ExpireStructure) EXPIREBYAT(key string, timestamp int64, tag ...string) error

+ func (ek *ExpireStructure) PERSIST(key string, seconds int64) error

+ func (ek *ExpireStructure) PEXPIRE(key string, milliseconds int64) error

+ func (ek *ExpireStructure) PEXPIREAT(key string, milliseconds_timestamp int64) error

+ func (ek *ExpireStructure) PEXPIREBY(key string, duration int64, tag ...string) error

+ func (ek *ExpireStructure) PEXPIREBYAT(key string, timestamp int64, tag ...string) error

+ func (ek *ExpireStructure) PTTL(key string) (int64, error)

+ func (ek *ExpireStructure) Stop() error

+ func (ek *ExpireStructure) TTL(key string) (int64, error)

type HashStructure

+ func (hs *HashStructure) Keys() ([]string, error)

type ListStructure

+ func (l *ListStructure) Keys() ([]string, error)

type SetStructure

+ func (s *SetStructure) Keys() ([]string, error)

+ func (s *SetStructure) Stop() error

type StringStructure

+ func (s *StringStructure) Keys() ([]string, error)

type ZSetStructure

+ func (d *ZSetStructure) Stop() error

+ func (zs *ZSetStructure) Keys() ([]string, error)

Jul 23, 2023

Changes in this version

+ var ErrMemberNotFound = errors.New("ErrMemberNotFound: member not found")

+ var ErrSetNotInitialized = errors.New("wrong operation: set not initialized")

+ type FSets map[string]struct

type ListStructure

+ func (s *ListStructure) Stop() error

+ type SetStructure struct

+ func NewSetStructure(options config.Options) (*SetStructure, error)

+ func (s *SetStructure) SAdd(key, member string) error

+ func (s *SetStructure) SAdds(key string, members ...string) error

+ func (s *SetStructure) SCard(key string) (int, error)

+ func (s *SetStructure) SDiff(keys ...string) ([]string, error)

+ func (s *SetStructure) SInter(keys ...string) ([]string, error)

+ func (s *SetStructure) SInterStore(destination string, keys ...string) error

+ func (s *SetStructure) SIsMember(key, member string) (bool, error)

+ func (s *SetStructure) SMembers(key string) ([]string, error)

+ func (s *SetStructure) SRem(key, member string) error

+ func (s *SetStructure) SRems(key string, members ...string) error

+ func (s *SetStructure) SUnion(keys ...string) ([]string, error)

+ func (s *SetStructure) SUnionStore(destination string, keys ...string) error

Jul 22, 2023

Changes in this version

+ const SKIPLIST_MAX_LEVEL

+ const SKIPLIST_PROB

+ var ErrAmountOfData = errors.New("The number of queries exceeds the amount of data in the stream")

+ var ErrExistID = errors.New("message ID already exists")

+ var ErrInvalidCount = errors.New("invalid count")

+ var ErrInvalidXArgs = errors.New("id or fields cannot be empty")

+ type FZSet struct

+ func (fzs *FZSet) Bytes() ([]byte, error)

+ func (fzs *FZSet) FromBytes(b []byte) error

+ func (fzs *FZSet) InsertNode(score int, member string, value interface{}) error

+ func (fzs *FZSet) MarshalBinary() (_ []byte, err error)

+ func (fzs *FZSet) RemoveNode(member string) error

+ func (fzs *FZSet) UnmarshalBinary(data []byte) (err error)

type HashStructure

+ func (hs *HashStructure) Clean()

+ func (hs *HashStructure) Stop() error

+ type SkipList struct

+ type SkipListLevel struct

+ type SkipListNode struct

+ type StreamGroup struct

+ LastDeliveredTime time.Time

+ LastGeneratedID string

+ Name string

+ PendingMessages map[string]*StreamMessage

+ type StreamMessage struct

+ Fields map[string]interface{}

+ Id string

+ type StreamStructure struct

+ func NewStreamStructure(options config.Options) (*StreamStructure, error)

+ func (s *StreamStructure) XAdd(name, id string, fields map[string]interface{}) (bool, error)

+ func (s *StreamStructure) XDel(name string, ids string) (bool, int, error)

+ func (s *StreamStructure) XGroup(name, group, id string) (bool, error)

+ func (s *StreamStructure) XLen(name string) (int, error)

+ func (s *StreamStructure) XRange(name string, start, stop int) ([]StreamMessage, error)

+ func (s *StreamStructure) XRead(name string, count int) ([]StreamMessage, error)

+ func (s *StreamStructure) XRevRange(name string, start, stop int) ([]StreamMessage, error)

+ func (s *StreamStructure) XTrim(name string, maxLen int) (int, error)

+ type Streams struct

+ Groups map[string]*StreamGroup

+ LastMessage time.Time

+ Messages []*StreamMessage

+ Name string

type StringStructure

+ func (s *StringStructure) MGet(keys ...string) ([]interface{}, error)

+ func (s *StringStructure) MSet(pairs ...interface{}) error

+ func (s *StringStructure) MSetNX(pairs ...interface{}) (bool, error)

+ type ZSetStructure struct

+ func NewZSetStructure(options config.Options) (*ZSetStructure, error)

+ func (zs *ZSetStructure) ZAdd(key string, score int, member string, value string) error

+ func (zs *ZSetStructure) ZAdds(key string, vals ...ZSetValue) error

+ func (zs *ZSetStructure) ZCard(key string) (int, error)

+ func (zs *ZSetStructure) ZCount(key string, min int, max int) (count int, err error)

+ func (zs *ZSetStructure) ZIncrBy(key string, member string, incBy int) error

+ func (zs *ZSetStructure) ZRange(key string, start int, end int) ([]ZSetValue, error)

+ func (zs *ZSetStructure) ZRank(key string, member string) (int, error)

+ func (zs *ZSetStructure) ZRem(key string, member string) error

+ func (zs *ZSetStructure) ZRems(key string, member ...string) error

+ func (zs *ZSetStructure) ZRevRange(key string, startRank int, endRank int) ([]ZSetValue, error)

+ func (zs *ZSetStructure) ZRevRank(key string, member string) (int, error)

+ func (zs *ZSetStructure) ZScore(key string, member string) (int, error)

+ type ZSetValue struct

+ func (d *ZSetValue) MarshalBinary() (_ []byte, err error)

+ func (p *ZSetValue) UnmarshalBinary(data []byte) (err error)

Jul 13, 2023

Changes in this version

+ var ErrInvalidArgs = errors.New("Error Args: The args are wrong")

+ type BitMapStructure struct

+ func NewBitMapStructure(options config.Options) (*BitMapStructure, error)

+ func (b *BitMapStructure) BitCount(key string, start uint, end uint) (int, error)

+ func (b *BitMapStructure) BitDel(key string, offset uint) error

+ func (b *BitMapStructure) BitDels(key string, offsets ...uint) error

+ func (b *BitMapStructure) BitOp(operation []byte, destkey string, keys ...string) error

+ func (b *BitMapStructure) GetBit(key string, offset uint) (bool, error)

+ func (b *BitMapStructure) GetBits(key string, offsets ...uint) ([]bool, error)

+ func (b *BitMapStructure) SetBit(key string, offset uint, value bool) error

+ func (b *BitMapStructure) SetBits(key string, args ...interface{}) error

Jul 11, 2023

Changes in this version

+ type BitOperation string

+ const BitAndOperation

+ const BitNotOperation

+ const BitOrOperation

+ const BitXorOperation

+ type BitSet struct

+ func (b *BitSet) At(pos uint) bool

+ func (b *BitSet) Next(pos uint) (uint, bool)

+ type BitmapStructure struct

+ func NewBitmap(options config.Options) (*BitmapStructure, error)

+ func (b *BitmapStructure) BitCount(k string, start, end uint) (uint, error)

+ func (b *BitmapStructure) BitOp(op BitOperation, destKey string, keys ...string) error

+ func (b *BitmapStructure) DelBit(k string, off uint) error

+ func (b *BitmapStructure) DelBits(k string, off ...uint) error

+ func (b *BitmapStructure) GetBit(k string, off uint) (bool, error)

+ func (b *BitmapStructure) GetBits(k string) (*BitSet, error)

+ func (b *BitmapStructure) SetBit(k string, off uint) error

+ func (b *BitmapStructure) SetBits(k string, off ...uint) error

type HashStructure

+ func (hs *HashStructure) HMGet(k string, f ...interface{}) ([]interface{}, error)

type StringStructure

+ func (s *StringStructure) Clean()

+ func (s *StringStructure) Stop() error

Jul 7, 2023

Changes in this version

+ type HashField struct

+ type HashMetadata struct

+ type HashStructure struct

+ func NewHashStructure(options config.Options) (*HashStructure, error)

+ func (hs *HashStructure) HDecrBy(k string, f interface{}, decrement int64) (int64, error)

+ func (hs *HashStructure) HDel(k string, f interface{}) (bool, error)

+ func (hs *HashStructure) HExists(k string, f interface{}) (bool, error)

+ func (hs *HashStructure) HGet(k string, f interface{}) (interface{}, error)

+ func (hs *HashStructure) HIncrBy(k string, f interface{}, increment int64) (int64, error)

+ func (hs *HashStructure) HIncrByFloat(k string, f interface{}, increment float64) (float64, error)

+ func (hs *HashStructure) HLen(k string) (int, error)

+ func (hs *HashStructure) HMove(source, destination string, f interface{}) (bool, error)

+ func (hs *HashStructure) HSet(k string, f, v interface{}) (bool, error)

+ func (hs *HashStructure) HSetNX(k string, f, v interface{}) (bool, error)

+ func (hs *HashStructure) HStrLen(k string, f interface{}) (int, error)

+ func (hs *HashStructure) HTypes(k string, f interface{}) (string, error)

+ func (hs *HashStructure) HUpdate(k string, f, v interface{}) (bool, error)

Jul 5, 2023

Changes in this version

+ var ErrIndexOutOfRange = errors.New("Wrong operation: index out of range")

+ var ErrInvalidType = errors.New("Wrong value: invalid type")

+ var ErrInvalidValue = errors.New("Wrong value: invalid value")

+ var ErrKeyExpired = errors.New("Wrong value: key expired")

+ var ErrListEmpty = errors.New("Wrong operation: list is empty")

+ var ErrWrongNumberOfArguments = errors.New("wrong number of arguments")

+ type DataStructure = byte

+ const Bitmap

+ const Expire

+ const Hash

+ const List

+ const Set

+ const Stream

+ const String

+ const ZSet

+ type ListStructure struct

+ func NewListStructure(options config.Options) (*ListStructure, error)

+ func (l *ListStructure) LIndex(key []byte, index int) ([]byte, error)

+ func (l *ListStructure) LLen(key []byte) (int, error)

+ func (l *ListStructure) LPop(key []byte) ([]byte, error)

+ func (l *ListStructure) LPush(key []byte, value []byte) error

+ func (l *ListStructure) LPushs(key []byte, values ...[]byte) error

+ func (l *ListStructure) LRange(key []byte, start int, stop int) ([][]byte, error)

+ func (l *ListStructure) LRem(key []byte, count int, value []byte) error

+ func (l *ListStructure) LSet(key []byte, index int, value []byte) error

+ func (l *ListStructure) LTrim(key []byte, start int, stop int) error

+ func (l *ListStructure) RPOPLPUSH(source []byte, destination []byte) error

+ func (l *ListStructure) RPop(key []byte) ([]byte, error)

+ func (l *ListStructure) RPush(key []byte, value []byte) error

+ func (l *ListStructure) RPushs(key []byte, values ...[]byte) error

+ type StringStructure struct

+ func NewStringStructure(options config.Options) (*StringStructure, error)

+ func (s *StringStructure) Append(key, value []byte, ttl time.Duration) error

+ func (s *StringStructure) Decr(key []byte, ttl time.Duration) error

+ func (s *StringStructure) DecrBy(key []byte, amount int, ttl time.Duration) error

+ func (s *StringStructure) Del(key []byte) error

+ func (s *StringStructure) Exists(key []byte) (bool, error)

+ func (s *StringStructure) Expire(key []byte, ttl time.Duration) error

+ func (s *StringStructure) Get(key []byte) ([]byte, error)

+ func (s *StringStructure) GetSet(key, value []byte, ttl time.Duration) ([]byte, error)

+ func (s *StringStructure) Incr(key []byte, ttl time.Duration) error

+ func (s *StringStructure) IncrBy(key []byte, amount int, ttl time.Duration) error

+ func (s *StringStructure) IncrByFloat(key []byte, amount float64, ttl time.Duration) error

+ func (s *StringStructure) Persist(key []byte) error

+ func (s *StringStructure) Set(key, value []byte, ttl time.Duration) error

+ func (s *StringStructure) StrLen(key []byte) (int, error)

+ func (s *StringStructure) Type(key []byte) (string, error)