MCPcopy Create free account

hub / github.com/danchia/ddb / functions

Functions265 in github.com/danchia/ddb

↓ 11 callersMethodLen
()
server/merge.go:93
↓ 9 callersMethodClose
Close closes the iterator.
server/iter.go:18
↓ 9 callersMethodInsert
(key string, data []byte)
sst/cache.go:104
↓ 8 callersMethodAdd
Add adds `key` to the bloom filter.
sst/bloom.go:50
↓ 8 callersMethodGet
Get retrieves k from cache. Returns nil if not found.
sst/cache.go:78
↓ 7 callersMethodAppend
Append writes a new row to the SSTable. Must be called in order, i.e. key asc, timestamp desc
sst/sstwriter.go:60
↓ 7 callersMethodBytes
Bytes() returns the bytes backing the bloom filter.
sst/bloom.go:45
↓ 7 callersMethodKey
Key returns the key of the current row.
server/iter.go:9
↓ 6 callersMethodInsert
Insert inserts (key, timestamp, value) into the memtable. Requires that (key, timestamp) does not already exist.
memtable/memtable.go:75
↓ 6 callersFunctionNew
(seqNo int64)
memtable/memtable.go:60
↓ 6 callersMethodNext
Next advances the iterator. Returns true if there is a next value.
server/iter.go:6
↓ 6 callersMethodTest
Test returns whether `key` is found.
sst/bloom.go:62
↓ 6 callersMethodTimestamp
Timestamp returns the timestamp of the current row.
server/iter.go:12
↓ 6 callersMethodUnRef
UnRef decreases the refcount by 1.
sst/sstreader.go:79
↓ 6 callersFunctionprefixDecodeFrom
prefixDecodeFrom decodes a prefix coded key from r. lastKey is nil for restart points. scratch will be used to created the returned key.
sst/prefixcoding.go:91
↓ 6 callersFunctionwriteUvarInt64
(w io.Writer, x uint64)
sst/util.go:40
↓ 5 callersMethodClose
Close finalizes the SST being written.
sst/sstwriter.go:89
↓ 5 callersFunctionDefaultOptions
(baseDir string)
server/server.go:49
↓ 5 callersMethodGet
(ctx context.Context, in *GetRequest, opts ...grpc.CallOption)
proto/ddb.pb.go:149
↓ 5 callersFunctionNewServer
(opts Options)
server/server.go:63
↓ 5 callersMethodSet
(ctx context.Context, in *SetRequest, opts ...grpc.CallOption)
proto/ddb.pb.go:150
↓ 5 callersFunctionrandomString
(minLength, maxLength int)
memtable/memtable_test.go:248
↓ 5 callersMethodreadRawBlock
(h blockHandle, fillCache bool)
sst/sstreader.go:148
↓ 4 callersMethodErr
Err returns last error, if any.
wal/scanner.go:102
↓ 4 callersMethodFilename
Filename returns the full file path of the SST.
sst/sstreader.go:94
↓ 4 callersMethodFind
Find returns value of key at largest timestamp, which could be nil for a deletion marker.
memtable/memtable.go:148
↓ 4 callersMethodGet
(ctx context.Context, req *pb.GetRequest)
server/server.go:74
↓ 4 callersMethodKey
()
sst/sstreader.go:273
↓ 4 callersMethodNewIter
NewIter returns a new SST iterator. Must close after use.
sst/sstreader.go:99
↓ 4 callersFunctionNewReader
NewReader returns a new SST reader for filename, already ref-ed once.
sst/sstreader.go:46
↓ 4 callersMethodReset
()
proto/ddb.pb.go:47
↓ 4 callersMethodReset
Reset resets the block. However, scratch memory may be retained.
sst/datablock.go:84
↓ 4 callersMethodTimestamp
()
sst/sstreader.go:281
↓ 4 callersMethodValue
()
sst/sstreader.go:277
↓ 4 callersMethodatomicLoadNext
(l int)
memtable/memtable.go:56
↓ 4 callersFunctionnewBlockHandle
(r io.ByteReader)
sst/common.go:53
↓ 4 callersFunctionrandomBytes
(minLength, maxLength int)
memtable/memtable_test.go:252
↓ 4 callersFunctionwriteUint32
(w io.Writer, x uint32)
sst/util.go:22
↓ 3 callersMethodAppend
Append appends a log record to the WAL. The log record is modified with the log sequence number. cb is invoked serially, in log sequence number order.
wal/writer.go:90
↓ 3 callersMethodClose
()
wal/writer.go:253
↓ 3 callersMethodEncodeTo
(w io.Writer)
sst/common.go:65
↓ 3 callersMethodFind
Find returns the value of key in SST.
sst/sstreader.go:104
↓ 3 callersMethodFinish
Finish finishes building the block and returns a slice to its contents. Returned slice is valid until Reset() is called.
sst/datablock.go:75
↓ 3 callersFunctionNewCache
NewCache returns a Cache.
sst/cache.go:42
↓ 3 callersFunctionNewIterFromRows
NewIterFromRows returns an Iter represents rows. rows must not be modified after.
server/iter.go:33
↓ 3 callersFunctionNewWriter
(nextSeq int64, opts Options)
wal/writer.go:64
↓ 3 callersFunctionNewWriter
(filename string)
sst/sstwriter.go:41
↓ 3 callersMethodSet
(ctx context.Context, req *pb.SetRequest)
server/server.go:70
↓ 3 callersMethodValue
Value returns the value of the current row.
server/iter.go:15
↓ 3 callersFunctionensureDir
(dir string)
server/database.go:158
↓ 3 callersFunctionnewBloom
()
sst/bloom.go:32
↓ 3 callersFunctionnewMergingIter
(iters []Iter)
server/merge.go:32
↓ 3 callersFunctionparseEKey
(eKey string)
sst/datablock.go:179
↓ 3 callersMethodwriteChecksummedBlock
(d []byte)
sst/sstwriter.go:127
↓ 2 callersMethodClose
()
sst/sstreader.go:285
↓ 2 callersMethodClose
Close closes the iterator.
sst/iter.go:31
↓ 2 callersMethodEncodeInto
EncodeInto encodes k into w, using shared prefix compression. Restarts are created every restartInterval, saving offset as the restart point.
sst/prefixcoding.go:28
↓ 2 callersMethodGetKey
()
proto/ddb.pb.go:52
↓ 2 callersMethodKey
Key returns the current key.
sst/iter.go:21
↓ 2 callersMethodNewIterator
NewIterator creates an iterator for this memtable.
memtable/memtable.go:169
↓ 2 callersMethodNext
Next advances the iterator. Returns true if there is a next value.
sst/sstreader.go:245
↓ 2 callersMethodNext
Next advances the iterator. Returns whether there is another key/value.
sst/iter.go:28
↓ 2 callersMethodRecord
Record returns the current record. Only valid until the next Scan() call. Caller should not modify returned proto.
wal/scanner.go:97
↓ 2 callersMethodRef
Ref increases the refcount by 1.
sst/sstreader.go:74
↓ 2 callersMethodSave
Save persists Descriptor to stable storage.
server/descriptor.go:146
↓ 2 callersMethodScan
Scan advances the fileScanner to the next log record, which will then be available through the Record method. It returns false when the scan stops, ei
wal/scanner.go:57
↓ 2 callersMethodSequenceUpper
SequenceUpper returns the largest sequence number applied.
memtable/memtable.go:118
↓ 2 callersMethodSizeBytes
SizeBytes returns the approximate memory used by this memtable.
memtable/memtable.go:111
↓ 2 callersMethodTimestamp
Timestamp returns the current timestamp.
memtable/memtable.go:188
↓ 2 callersMethodValue
Value returns the current value. Callers should not modify the returned value. Returned value is only valid until the next call to Next.
sst/iter.go:25
↓ 2 callersMethodWriteRestarts
WriteRestarts writes out the restarts to w
sst/prefixcoding.go:77
↓ 2 callersMethodapply
(l *pb.LogRecord)
server/database.go:209
↓ 2 callersMethodatomicStoreNext
(l int, x *node)
memtable/memtable.go:52
↓ 2 callersMethodfilenameFor
(version int64)
server/descriptor.go:203
↓ 2 callersMethodfindGreaterOrEqual
findGreaterOrEqual retuns the first node that is greater than or equal to (key, timestamp). according to (key, timestamp) ordering. If prev is not nil
memtable/memtable.go:127
↓ 2 callersMethodflushBlock
()
sst/sstwriter.go:71
↓ 2 callersFunctionlistLogFiles
(dirname string)
wal/common.go:17
↓ 2 callersMethodmaybeTriggerFlush
()
server/database.go:221
↓ 2 callersFunctionnewDataBlock
(d []byte)
sst/datablock.go:94
↓ 2 callersFunctionnewIndexBlock
(d []byte)
sst/indexblock.go:67
↓ 2 callersFunctionnewKeyGenerator
()
ddbc/cmd/loaddata.go:90
↓ 2 callersFunctionnewPrefixEncoder
(restartInterval int32)
sst/prefixcoding.go:18
↓ 2 callersMethodnext
()
ddbc/cmd/loaddata.go:94
↓ 2 callersMethodpickLevel
Level assigned to this node, zero indexed.
memtable/memtable.go:201
↓ 2 callersMethodrollover
(seq int64)
wal/writer.go:142
↓ 2 callersMethodrunEviction
Requires c.mu be held.
sst/cache.go:121
↓ 2 callersFunctionvalidateKey
(k string)
server/database.go:528
↓ 2 callersFunctionverifyChecksum
(data []byte, sum []byte)
sst/sstreader.go:211
↓ 2 callersMethodwriteRawRecord
(r rawRecord)
wal/writer.go:220
↓ 1 callersMethodBlocks
Blocks returns the list of data blocks in this index.
sst/indexblock.go:128
↓ 1 callersMethodClose
Close closes the iterator by closing all the underlying iters.
server/merge.go:85
↓ 1 callersMethodClose
Close closes the iterator.
memtable/memtable.go:198
↓ 1 callersMethodEstimatedSizeBytes
EstimatedSizeBytes returns the estimated current size of the block.
sst/datablock.go:69
↓ 1 callersMethodFind
(ctx context.Context, key string)
server/database.go:228
↓ 1 callersMethodGetSstMeta
()
proto/internal.pb.go:116
↓ 1 callersMethodGetValue
()
proto/ddb.pb.go:108
↓ 1 callersMethodKey
Key returns the current key.
memtable/memtable.go:183
↓ 1 callersFunctionLoadDescriptor
LoadDescriptor loads the highest numbered descriptor found in dir.
server/descriptor.go:68
↓ 1 callersFunctionNewDescriptor
NewDescriptor returns a Descriptor for a brand new database. Most use cases should probably use LoadDescriptor instead.
server/descriptor.go:59
↓ 1 callersMethodNewID
NewID returns a new unique ID, typically used by callers to partition to cache space by pre-pending the ID to all cache keys.
sst/cache.go:68
next →1–100 of 265, ranked by callers