CheckIsExist check the given key from db if exist

IsErrorReply returns true if the given reply is error

MakeNullBulkReply creates a new NullBulkReply

New creates a new Consistent object with a default setting of 20 replicas for each entry. To change the number of replicas, set NumberOfReplicas befo

NewBTree Init BTree struct

NewSingleDB create single DB instance

OpenDataFile Open new datafile

OpenHintFile Open new datafile

OpenMergeFinishedFile Open new datafile

ParseStream reads data from io.Reader and send payloads through channel

Read By specifying the location data in a read the file

Removes the given keys from db

parse Resp and use db exec the request if this node is not responsible for the request, then Forward the request(store the useful node in the context)

SetupEngine creates a RespHandler instance

WaitWithTimeout blocks until the WaitGroup counter is zero or timeout returns true if timeout

need c.Lock() before calling

begin

broadcast broadcasts command to all node in cluster

Check for conflicts and finally perform a commit or rollback

compareSlices checks if two slices of byte slices (a and b)have the same elements, regardless of order. It returns true if they have the same element

eltKey generates a string key for an element with an index.

func (db DB) loadTxFile() error { fileName := filepath.Join(db.options.DirPath, public.TxIDFileName) if _, err := os.Stat(fileName); os.IsNotExist(e

create a new directory

need c.Lock() before calling

CompilePattern convert wildcard string to Pattern

EncodeLogRecordPos encode the pos info

Flush clean database

OpenTxIDFile Open new datafile func OpenTxIDFile(dirPath string) (*DataFile, error) { fileName := filepath.Join(dirPath, public.TxIDFileName) return