MCPcopy Create free account

hub / github.com/danchia/ddb / functions

Functions265 in github.com/danchia/ddb

↓ 1 callersFunctionNewScanner
NewScanner returns a log scanner over all the log files found in dirname. Returns ErrNotExist if there are no log files.
wal/scanner.go:45
↓ 1 callersMethodNext
Next advances the iterator. Returns true if there is a next value.
memtable/memtable.go:177
↓ 1 callersMethodPop
()
server/merge.go:114
↓ 1 callersMethodPush
(x interface{})
server/merge.go:110
↓ 1 callersMethodRestarts
Restarts returns the restart points.
sst/prefixcoding.go:65
↓ 1 callersMethodString
()
proto/ddb.pb.go:48
↓ 1 callersMethodValue
Value returns the current value.
memtable/memtable.go:193
↓ 1 callersFunctionappendSync
(w *Writer, l *pb.LogRecord)
wal/wal_test.go:124
↓ 1 callersFunctionbenchWorker
(args workerArgs)
ddbc/cmd/bench.go:110
↓ 1 callersMethodcleanUnusedFiles
()
server/database.go:332
↓ 1 callersMethodclose
()
sst/sstreader.go:86
↓ 1 callersMethodcompact
compact compacts ssts into a single SST and modifies the descriptor as appropriate.
server/database.go:417
↓ 1 callersMethodcompactor
compactor monitors the number of SSTs, and triggers compaction when necessary. Currently the scheme is a very simple one - if there are more than 8 SS
server/database.go:400
↓ 1 callersMethodfindDataBlock
findDataBlock finds the first data block containing key. Returns ErrNotFound if key could not be found.
sst/sstreader.go:135
↓ 1 callersFunctionfindLatestFile
(dir string)
server/descriptor.go:117
↓ 1 callersMethodflushIMemtable
()
server/database.go:284
↓ 1 callersMethodformRecord
(l *pb.LogRecord)
wal/writer.go:105
↓ 1 callersFunctiongenValue
()
ddbc/cmd/loaddata.go:102
↓ 1 callersMethodgetFilterBlock
()
sst/sstreader.go:125
↓ 1 callersFunctiongetSstDirFiles
(sstDir string)
server/database.go:380
↓ 1 callersFunctionlogName
(nextSeq int64, o Options)
wal/writer.go:138
↓ 1 callersMethodmaybeAdvanceFileScanner
returns whether attempted advance was successful
wal/scanner.go:76
↓ 1 callersFunctionnewBloomFromBytes
(b []byte)
sst/bloom.go:38
↓ 1 callersFunctionnewDataBlockBuilder
()
sst/datablock.go:33
↓ 1 callersFunctionnewDatabase
(opts Options)
server/database.go:56
↓ 1 callersFunctionnewFileScanner
(name string)
wal/scanner.go:121
↓ 1 callersFunctionnewFilterBlock
(b []byte)
sst/filter_block.go:39
↓ 1 callersFunctionnewFilterBlockBuilder
()
sst/filter_block.go:21
↓ 1 callersFunctionnewIndexBlockBuilder
()
sst/indexblock.go:31
↓ 1 callersFunctionnewIter
(r *Reader)
sst/sstreader.go:229
↓ 1 callersFunctionparseFilename
(n string)
wal/common.go:44
↓ 1 callersMethodreadFooter
()
sst/sstreader.go:180
↓ 1 callersMethodrecoverLog
(lastApplied int64)
server/database.go:112
↓ 1 callersFunctionrunTrial
runTrial returns the false positive ratio
sst/bloom_test.go:60
↓ 1 callersFunctionstartDebugServer
()
ddbcli/main.go:62
↓ 1 callersMethodswapMemtableLocked
()
server/database.go:278
↓ 1 callersMethodsync
()
wal/writer.go:246
↓ 1 callersFunctionvalidateValue
(v []byte)
server/database.go:538
↓ 1 callersMethodwriteFilterBlock
writeFilterBlock writes the filter block and returns a blockHandle pointing to it.
sst/sstwriter.go:121
↓ 1 callersMethodwriteFooter
(indexHandle blockHandle, filterHandle blockHandle)
sst/sstwriter.go:146
↓ 1 callersMethodwriteIndexBlock
writeIndexBlock writes the index block and returns a blockHandle pointing to it.
sst/sstwriter.go:111
↓ 1 callersMethodwriteLoop
()
wal/writer.go:171
↓ 1 callersFunctionwriteUint64
(w io.Writer, x uint64)
sst/util.go:31
MethodAppend
Append writes a new row to the block.
sst/datablock.go:41
MethodAppend
Append adds a key to the filter block.
sst/filter_block.go:26
MethodAppend
(key string, bh blockHandle)
sst/indexblock.go:39
FunctionBenchmarkConcurrentAppend
(b *testing.B)
wal/wal_bench_test.go:27
FunctionBenchmarkFind
(b *testing.B)
memtable/memtable_test.go:216
FunctionBenchmarkInsert
(b *testing.B)
memtable/memtable_test.go:180
FunctionCleanUnusedFiles
CleanUnusedFiles cleans unused log files, i.e those that have already been applied.
wal/cleaner.go:11
MethodClose
()
server/iter.go:58
MethodDescriptor
()
proto/ddb.pb.go:50
MethodDescriptor
()
proto/ddb.pb.go:68
MethodDescriptor
()
proto/ddb.pb.go:99
MethodDescriptor
()
proto/ddb.pb.go:122
MethodDescriptor
()
proto/internal.pb.go:47
MethodDescriptor
()
proto/internal.pb.go:77
MethodDescriptor
()
proto/internal.pb.go:114
MethodDescriptor
()
proto/internal.pb.go:133
MethodEnumDescriptor
()
proto/internal.pb.go:37
MethodErr
Returns last error, if any.
wal/scanner.go:182
FunctionExecute
Execute adds all child commands to the root command and sets flags appropriately. This is called by main.main(). It only needs to happen once to the r
ddbc/cmd/root.go:36
MethodFind
(key string)
sst/datablock.go:108
MethodFind
(key string)
sst/indexblock.go:81
MethodFinish
Finish finishes building the filter block and returns a slice to its contents.
sst/filter_block.go:31
MethodFinish
()
sst/indexblock.go:55
MethodGet
(ctx context.Context, in *GetRequest, opts ...grpc.CallOption)
proto/ddb.pb.go:161
MethodGet
(context.Context, *GetRequest)
proto/ddb.pb.go:182
MethodGetAppliedUntil
()
proto/internal.pb.go:142
FunctionGetDDB
GetDDB returns a DDB stub.
ddbc/common/common.go:28
MethodGetFilename
()
proto/internal.pb.go:135
MethodGetKey
()
proto/ddb.pb.go:70
MethodGetKey
()
proto/ddb.pb.go:101
MethodGetKey
()
proto/internal.pb.go:79
MethodGetMutation
()
proto/internal.pb.go:56
MethodGetSequence
()
proto/internal.pb.go:49
MethodGetTimestamp
()
proto/ddb.pb.go:77
MethodGetTimestamp
()
proto/ddb.pb.go:124
MethodGetTimestamp
()
proto/internal.pb.go:93
MethodGetType
()
proto/internal.pb.go:86
MethodGetValue
()
proto/ddb.pb.go:84
MethodGetValue
()
proto/internal.pb.go:100
MethodKey
()
sst/datablock.go:203
MethodKey
Key returns the current key.
server/merge.go:76
MethodKey
()
server/iter.go:46
MethodLess
(i, j int)
server/merge.go:95
FunctionNewDdbClient
(cc *grpc.ClientConn)
proto/ddb.pb.go:157
MethodNewIter
()
sst/datablock.go:198
MethodNext
()
sst/datablock.go:215
MethodNext
Next advances the iterator. Returns true if there is a next value.
server/merge.go:53
MethodNext
()
server/iter.go:37
MethodProtoMessage
()
proto/ddb.pb.go:49
MethodProtoMessage
()
proto/ddb.pb.go:67
MethodProtoMessage
()
proto/ddb.pb.go:98
MethodProtoMessage
()
proto/ddb.pb.go:121
MethodProtoMessage
()
proto/internal.pb.go:46
MethodProtoMessage
()
proto/internal.pb.go:76
MethodProtoMessage
()
proto/internal.pb.go:113
MethodProtoMessage
()
proto/internal.pb.go:132
MethodReadByte
()
sst/util.go:59
← previousnext →101–200 of 265, ranked by callers