Versions in this module Expand all Collapse all v1 v1.0.10 Apr 30, 2025 v1.0.9 Apr 29, 2025 v1.0.8 Apr 29, 2025 v1.0.7 Apr 24, 2025 v1.0.6 Apr 17, 2025 v1.0.5 Apr 16, 2025 v1.0.4 Mar 23, 2025 v1.0.3 Mar 16, 2025 v1.0.2 Mar 16, 2025 v1.0.1 Mar 10, 2025 v1.0.0 Mar 9, 2025 Changes in this version + const AND + const After + const Async + const BIT + const BYTE + const Before + const CAPACITY + const CH + const Count + const CountConst + const Docs + const EXPANSION + const Ex + const Exat + const FAIL + const FILTERS + const GET + const GT + const GetKeys + const GetKeysandFlags + const Help + const INCR + const INCRBY + const ITEMS + const IncrBy + const Info + const Initialized + const KeepTTL + const LT + const List + const Memory + const MultBy + const NOT + const NX + const OR + const OVERFLOW + const Persist + const Px + const Pxat + const REV + const SAT + const SET + const SIGNED + const SIZE + const Sync + const UNSIGNED + const Uninitialized + const WRAP + const WithScore + const WithScores + const WithValues + const XOR + const XX + var DiceCmds = map[string]DiceCmdMeta + var ErrDequeEmpty = errors.New("deque is empty") + var PreProcessing = map[string]func([]string, *dstore.Store) *EvalResponse + var RespEmptyArray = []byte("*0\r\n") + var RespMinusOne = []byte(":-1\r\n") + var RespMinusTwo = []byte(":-2\r\n") + var RespNIL = []byte("$-1\r\n") + var RespOK = []byte("+OK\r\n") + var RespOne = []byte(":1\r\n") + var RespQueued = []byte("+QUEUED\r\n") + var RespZero = []byte(":0\r\n") + var TxnCommands map[string]bool + func ByteSliceToByteArrayObj(store *dstore.Store, oldObj *object.Obj, b []byte) (*object.Obj, error) + func ByteSliceToIntObj(store *dstore.Store, oldObj *object.Obj, b []byte) (*object.Obj, error) + func ByteSliceToObj(store *dstore.Store, oldObj *object.Obj, b []byte, objType object.ObjectType) (*object.Obj, error) + func ByteSliceToStringObj(store *dstore.Store, oldObj *object.Obj, b []byte) (*object.Obj, error) + func DecodeDeqEntry(xb []byte) (x string, entryLen int) + func Encode(value interface{}, isSimple bool) []byte + func EncodeDeqEntry(x string) []byte + func EncodeDeqEntryInPlace(x string, buf []byte) + func EncodeDeqInt(v int64) []byte + func EncodeDeqIntInPlace(v int64, buf []byte) + func EncodeDeqStr(x string) []byte + func EncodeDeqStrInPlace(x string, buf []byte) + func EvalAUTH(args []string, c *comm.Client) []byte + func GetEncodeDeqEntrySize(x string) uint64 + func GetEncodeDeqIntSize(v int64) uint64 + func GetEncodeDeqStrSize(x string) uint64 + func IsInt64(v interface{}) bool + func IsString(v interface{}) bool + type Bloom struct + func CreateOrReplaceBloomFilter(key string, opts *BloomOpts, store *dstore.Store) *Bloom + func DeserializeBloom(buf *bytes.Reader) (*Bloom, error) + func GetBloomFilter(key string, store *dstore.Store) (*Bloom, error) + func GetOrCreateBloomFilter(key string, store *dstore.Store, opts *BloomOpts) (*Bloom, error) + func NewBloomFilter(opts *BloomOpts) *Bloom + func (b *Bloom) DeepCopy() *Bloom + func (b *Bloom) Serialize(buf *bytes.Buffer) error + type BloomOpts struct + type ByteArray struct + Length int64 + func NewByteArray(size int) *ByteArray + func NewByteArrayFromObj(obj *object.Obj) (*ByteArray, error) + func (b *ByteArray) BitCount() int + func (b *ByteArray) DeepCopy() *ByteArray + func (b *ByteArray) GetBit(pos int) bool + func (b *ByteArray) IncreaseSize(increaseSizeTo int) *ByteArray + func (b *ByteArray) ResizeIfNecessary() *ByteArray + func (b *ByteArray) SetBit(pos int, value bool) + type CountMinSketch struct + func DeserializeCMS(buffer *bytes.Reader) (*CountMinSketch, error) + func (c *CountMinSketch) DeepCopy() *CountMinSketch + type CountMinSketchOpts struct + type Deque struct + Length int64 + func DeserializeDeque(buf *bytes.Reader) (*Deque, error) + func NewDeque() *Deque + func (q *Deque) GetLength() int64 + func (q *Deque) LInsert(pivot, element, beforeAfter string) (int64, error) + func (q *Deque) LPop() (string, error) + func (q *Deque) LPush(x string) + func (q *Deque) LRange(start, stop int64) ([]string, error) + func (q *Deque) NewIterator() *DequeIterator + func (q *Deque) RPop() (string, error) + func (q *Deque) RPush(x string) + func (q *Deque) Serialize(buf *bytes.Buffer) error + type DequeBasic struct + Length int64 + func NewBasicDeque() *DequeBasic + func (q *DequeBasic) GetLength() int64 + func (q *DequeBasic) LInsert(pivot, element, beforeAfter string) (int64, error) + func (q *DequeBasic) LPop() (string, error) + func (q *DequeBasic) LPush(x string) + func (q *DequeBasic) LRange(start, stop int64) ([]string, error) + func (q *DequeBasic) NewIterator() *DequeBasicIterator + func (q *DequeBasic) RPop() (string, error) + func (q *DequeBasic) RPush(x string) + type DequeBasicIterator struct + func (i *DequeBasicIterator) HasNext() bool + func (i *DequeBasicIterator) Next() (string, error) + type DequeI interface + GetLength func() int64 + LInsert func(string, string, string) (int64, error) + LPop func() (string, error) + LPush func(string) + LRange func(start, stop int64) ([]string, error) + RPop func() (string, error) + RPush func(string) + type DequeIterator struct + BufIndex int + CurrentNode *byteListNode + ElementsTraversed int64 + func (i *DequeIterator) HasNext() bool + func (i *DequeIterator) Next() (string, error) + type DiceCmdMeta struct + Arity int + Eval func([]string, *dstore.Store) []byte + Info string + IsMigrated bool + Name string + NewEval func([]string, *dstore.Store) *EvalResponse + StoreObjectEval func(*cmd.DiceDBCmd, *dstore.Store) *EvalResponse + SubCommands []string + type Eval struct + func NewEval(c *cmd.DiceDBCmd, client *comm.Client, store *dstore.Store, ...) *Eval + func (e *Eval) ExecuteCommand() *EvalResponse + func (e *Eval) PreProcessCommand() *EvalResponse + type EvalResponse struct + Error error + Result interface{} + type HashMap map[string]string + func (h HashMap) Get(k string) (*string, bool) + func (h HashMap) Set(k, v string) (*string, bool) + type KeySpecs struct + BeginIndex int + LastKey int + Step int + type RespType int + const CommandQueued + const EmptyArray + const IntegerNegativeOne + const IntegerNegativeTwo + const IntegerOne + const IntegerZero + const NIL + const OK + type String struct + func NewString(value string) *String + func (s *String) Serialize() []byte v0 v0.1.0 Nov 22, 2024
Go to main page