Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/danchia/ddb
/ functions
Functions
265 in github.com/danchia/ddb
⨍
Functions
265
◇
Types & classes
55
↓ 1 callers
Function
NewScanner
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 callers
Method
Next
Next advances the iterator. Returns true if there is a next value.
memtable/memtable.go:177
↓ 1 callers
Method
Pop
()
server/merge.go:114
↓ 1 callers
Method
Push
(x interface{})
server/merge.go:110
↓ 1 callers
Method
Restarts
Restarts returns the restart points.
sst/prefixcoding.go:65
↓ 1 callers
Method
String
()
proto/ddb.pb.go:48
↓ 1 callers
Method
Value
Value returns the current value.
memtable/memtable.go:193
↓ 1 callers
Function
appendSync
(w *Writer, l *pb.LogRecord)
wal/wal_test.go:124
↓ 1 callers
Function
benchWorker
(args workerArgs)
ddbc/cmd/bench.go:110
↓ 1 callers
Method
cleanUnusedFiles
()
server/database.go:332
↓ 1 callers
Method
close
()
sst/sstreader.go:86
↓ 1 callers
Method
compact
compact compacts ssts into a single SST and modifies the descriptor as appropriate.
server/database.go:417
↓ 1 callers
Method
compactor
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 callers
Method
findDataBlock
findDataBlock finds the first data block containing key. Returns ErrNotFound if key could not be found.
sst/sstreader.go:135
↓ 1 callers
Function
findLatestFile
(dir string)
server/descriptor.go:117
↓ 1 callers
Method
flushIMemtable
()
server/database.go:284
↓ 1 callers
Method
formRecord
(l *pb.LogRecord)
wal/writer.go:105
↓ 1 callers
Function
genValue
()
ddbc/cmd/loaddata.go:102
↓ 1 callers
Method
getFilterBlock
()
sst/sstreader.go:125
↓ 1 callers
Function
getSstDirFiles
(sstDir string)
server/database.go:380
↓ 1 callers
Function
logName
(nextSeq int64, o Options)
wal/writer.go:138
↓ 1 callers
Method
maybeAdvanceFileScanner
returns whether attempted advance was successful
wal/scanner.go:76
↓ 1 callers
Function
newBloomFromBytes
(b []byte)
sst/bloom.go:38
↓ 1 callers
Function
newDataBlockBuilder
()
sst/datablock.go:33
↓ 1 callers
Function
newDatabase
(opts Options)
server/database.go:56
↓ 1 callers
Function
newFileScanner
(name string)
wal/scanner.go:121
↓ 1 callers
Function
newFilterBlock
(b []byte)
sst/filter_block.go:39
↓ 1 callers
Function
newFilterBlockBuilder
()
sst/filter_block.go:21
↓ 1 callers
Function
newIndexBlockBuilder
()
sst/indexblock.go:31
↓ 1 callers
Function
newIter
(r *Reader)
sst/sstreader.go:229
↓ 1 callers
Function
parseFilename
(n string)
wal/common.go:44
↓ 1 callers
Method
readFooter
()
sst/sstreader.go:180
↓ 1 callers
Method
recoverLog
(lastApplied int64)
server/database.go:112
↓ 1 callers
Function
runTrial
runTrial returns the false positive ratio
sst/bloom_test.go:60
↓ 1 callers
Function
startDebugServer
()
ddbcli/main.go:62
↓ 1 callers
Method
swapMemtableLocked
()
server/database.go:278
↓ 1 callers
Method
sync
()
wal/writer.go:246
↓ 1 callers
Function
validateValue
(v []byte)
server/database.go:538
↓ 1 callers
Method
writeFilterBlock
writeFilterBlock writes the filter block and returns a blockHandle pointing to it.
sst/sstwriter.go:121
↓ 1 callers
Method
writeFooter
(indexHandle blockHandle, filterHandle blockHandle)
sst/sstwriter.go:146
↓ 1 callers
Method
writeIndexBlock
writeIndexBlock writes the index block and returns a blockHandle pointing to it.
sst/sstwriter.go:111
↓ 1 callers
Method
writeLoop
()
wal/writer.go:171
↓ 1 callers
Function
writeUint64
(w io.Writer, x uint64)
sst/util.go:31
Method
Append
Append writes a new row to the block.
sst/datablock.go:41
Method
Append
Append adds a key to the filter block.
sst/filter_block.go:26
Method
Append
(key string, bh blockHandle)
sst/indexblock.go:39
Function
BenchmarkConcurrentAppend
(b *testing.B)
wal/wal_bench_test.go:27
Function
BenchmarkFind
(b *testing.B)
memtable/memtable_test.go:216
Function
BenchmarkInsert
(b *testing.B)
memtable/memtable_test.go:180
Function
CleanUnusedFiles
CleanUnusedFiles cleans unused log files, i.e those that have already been applied.
wal/cleaner.go:11
Method
Close
()
server/iter.go:58
Method
Descriptor
()
proto/ddb.pb.go:50
Method
Descriptor
()
proto/ddb.pb.go:68
Method
Descriptor
()
proto/ddb.pb.go:99
Method
Descriptor
()
proto/ddb.pb.go:122
Method
Descriptor
()
proto/internal.pb.go:47
Method
Descriptor
()
proto/internal.pb.go:77
Method
Descriptor
()
proto/internal.pb.go:114
Method
Descriptor
()
proto/internal.pb.go:133
Method
EnumDescriptor
()
proto/internal.pb.go:37
Method
Err
Returns last error, if any.
wal/scanner.go:182
Function
Execute
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
Method
Find
(key string)
sst/datablock.go:108
Method
Find
(key string)
sst/indexblock.go:81
Method
Finish
Finish finishes building the filter block and returns a slice to its contents.
sst/filter_block.go:31
Method
Finish
()
sst/indexblock.go:55
Method
Get
(ctx context.Context, in *GetRequest, opts ...grpc.CallOption)
proto/ddb.pb.go:161
Method
Get
(context.Context, *GetRequest)
proto/ddb.pb.go:182
Method
GetAppliedUntil
()
proto/internal.pb.go:142
Function
GetDDB
GetDDB returns a DDB stub.
ddbc/common/common.go:28
Method
GetFilename
()
proto/internal.pb.go:135
Method
GetKey
()
proto/ddb.pb.go:70
Method
GetKey
()
proto/ddb.pb.go:101
Method
GetKey
()
proto/internal.pb.go:79
Method
GetMutation
()
proto/internal.pb.go:56
Method
GetSequence
()
proto/internal.pb.go:49
Method
GetTimestamp
()
proto/ddb.pb.go:77
Method
GetTimestamp
()
proto/ddb.pb.go:124
Method
GetTimestamp
()
proto/internal.pb.go:93
Method
GetType
()
proto/internal.pb.go:86
Method
GetValue
()
proto/ddb.pb.go:84
Method
GetValue
()
proto/internal.pb.go:100
Method
Key
()
sst/datablock.go:203
Method
Key
Key returns the current key.
server/merge.go:76
Method
Key
()
server/iter.go:46
Method
Less
(i, j int)
server/merge.go:95
Function
NewDdbClient
(cc *grpc.ClientConn)
proto/ddb.pb.go:157
Method
NewIter
()
sst/datablock.go:198
Method
Next
()
sst/datablock.go:215
Method
Next
Next advances the iterator. Returns true if there is a next value.
server/merge.go:53
Method
Next
()
server/iter.go:37
Method
ProtoMessage
()
proto/ddb.pb.go:49
Method
ProtoMessage
()
proto/ddb.pb.go:67
Method
ProtoMessage
()
proto/ddb.pb.go:98
Method
ProtoMessage
()
proto/ddb.pb.go:121
Method
ProtoMessage
()
proto/internal.pb.go:46
Method
ProtoMessage
()
proto/internal.pb.go:76
Method
ProtoMessage
()
proto/internal.pb.go:113
Method
ProtoMessage
()
proto/internal.pb.go:132
Method
ReadByte
()
sst/util.go:59
← previous
next →
101–200 of 265, ranked by callers