MCPcopy Create free account

hub / github.com/ankur-anand/unisondb / functions

Functions3,181 in github.com/ankur-anand/unisondb

⨍ Functions 3,181◇ Types & classes 414
↓ 3 callersMethodhandleFlush
handleFlush flushes the sealed mem-table to btree store.
dbkernel/engine.go:835
↓ 3 callersMethodhandleRecord
(record *logrecord.LogRecord, offset *Offset)
dbkernel/replica.go:283
↓ 3 callersMethodincrRef
()
pkg/walfs/segment.go:1154
↓ 3 callersMethodinitStorage
(dataDir, namespace string, conf *EngineConfig)
dbkernel/engine.go:290
↓ 3 callersFunctionisBenignBlobStoreStreamerError
(err error)
cmd/unisondb/cliapp/service_blob_store_streamer.go:310
↓ 3 callersMethodmonitor
(ctx context.Context)
internal/services/relayer/relayer.go:319
↓ 3 callersMethodnamespaceState
(ctx context.Context, namespace string)
internal/services/streamer/blob_store_steamer.go:296
↓ 3 callersFunctionnewClusterBuilder
(nodeID, namespace, dataDir string, nodes []nodeConfig)
pkg/raftcluster/builder_test.go:39
↓ 3 callersFunctionnewTestSlogLogger
(buf *bytes.Buffer)
pkg/raftcluster/hc_slog_test.go:16
↓ 3 callersFunctionnextReconcileInterval
(rng *rand.Rand)
pkg/raftcluster/membership.go:385
↓ 3 callersMethodnotifyClusters
notifyClusters sends membership events to all registered cluster listeners.
pkg/raftcluster/membership.go:158
↓ 3 callersFunctionopenLMDBTemp
(t *testing.T)
pkg/kvdrivers/lmdb_test.go:51
↓ 3 callersMethodopenLog
(namespace string)
internal/services/streamer/blob_store_steamer.go:487
↓ 3 callersFunctionparseLogLevel
(levelStr string)
cmd/unisondb/cliapp/helpers.go:45
↓ 3 callersFunctionprepareFlatBufferRowUpdateEntry
(builder *flatbuffers.Builder)
internal/benchtests/serialization/bench_test.go:17
↓ 3 callersFunctionrandKey
(length int)
internal/services/fuzzer/fuzz_engine.go:48
↓ 3 callersMethodrecordOpResult
(op string, start time.Time, err error)
pkg/kvdrivers/lmdb.go:376
↓ 3 callersFunctionrecordOverhead
(dataLen int64)
pkg/walfs/walog.go:574
↓ 3 callersMethodrecordRaftApplied
(log *raft.Log)
dbkernel/engine_raft.go:158
↓ 3 callersMethodreleaseRef
releaseRef decrements the reference count and performs any deferred cleanup.
pkg/walfs/segment.go:1165
↓ 3 callersMethodreplicateFromReader
replicateFromReader reads the underlying wal until an err is encountered.
pkg/replicator/replicator.go:115
↓ 3 callersFunctionrequireSegmentFirstIndex
(t *testing.T, walog *walfs.WALog, expected uint64)
dbkernel/replica_test.go:703
↓ 3 callersMethodrotateSegment
()
pkg/walfs/walog.go:727
↓ 3 callersFunctionsafeTestPath
(s string)
internal/services/streamer/blob_store_provider_integration_test.go:212
↓ 3 callersFunctionserializeLogRecord
Prepare main LogRecord with encoded rows
internal/benchtests/serialization/bench_test.go:196
↓ 3 callersFunctionserializeLogRecord
SerializeLogRecord encodes a LogRecord to binary format using FlatBuffers.
internal/logcodec/codec.go:9
↓ 3 callersFunctionserializeProtoLogRecord
Serialize LogRecord embedding pre-encoded RowUpdateEntries.
internal/benchtests/serialization/bench_test.go:306
↓ 3 callersFunctionserializeProtoWithLargeValue
--- Protobuf serialization ---
internal/benchtests/serialization/bench_test.go:439
↓ 3 callersFunctionsetupMemTableWithBoltDB
(t *testing.T, capacity int64)
dbkernel/internal/memtable/memtable_test.go:61
↓ 3 callersFunctionsetupSingleNodeRaftWithEngineWAL
(t *testing.T, engine *Engine)
dbkernel/engine_raft_test.go:104
↓ 3 callersFunctionsetupTestServerWithConfig
(t *testing.T, modify func(cfg *dbkernel.EngineConfig))
internal/services/httpapi/service_test.go:37
↓ 3 callersFunctionsetupTestServerWithOptions
(t *testing.T, modifyCfg func(cfg *dbkernel.EngineConfig), modifyService func(s *Service))
internal/services/httpapi/service_test.go:41
↓ 3 callersMethodshard
shard returns the appropriate shard for the given ID.
pkg/walfs/util.go:41
↓ 3 callersFunctionsimulateWALIO
simulateWALIO simulates I/O operations returning some bytes
internal/benchtests/broadcast/bench/ctxtimeout/main_test.go:46
↓ 3 callersMethodstartTerm
(ctx context.Context, namespace string)
cmd/unisondb/cliapp/service_blob_store_streamer.go:224
↓ 3 callersFunctiontestPeerCommunication
(t *testing.T, dialer, acceptor *NamespaceStreamLayer, targetAddr string)
pkg/raftmux/integration_test.go:68
↓ 3 callersFunctionwrapRaftError
(err error)
dbkernel/raft_txn.go:265
↓ 2 callersMethodAppendColumnTxn
(rowKey []byte, columnEntries map[string][]byte)
dbkernel/txn.go:59
↓ 2 callersMethodAppliedTerm
AppliedTerm returns the last applied Raft log term.
dbkernel/engine_raft.go:396
↓ 2 callersMethodBatchSetKV
(keys [][]byte, values [][]byte)
dbkernel/internal/common.go:28
↓ 2 callersMethodBatchSetKV
(keys [][]byte, value [][]byte)
pkg/kvdrivers/suite_test.go:21
↓ 2 callersFunctionBuildDefaultRelayerServiceConfigJSON
BuildDefaultRelayerServiceConfigJSON build Config JSON for grpc client for the WalStreaming Service.
pkg/svcutils/relayer_conf.go:9
↓ 2 callersMethodBuildDeps
()
cmd/unisondb/cliapp/service.go:97
↓ 2 callersMethodClose
Close gracefully shuts down the segment by waiting for all active readers to complete. It unmap the segment file and closes file descriptor.
pkg/walfs/segment.go:1065
↓ 2 callersMethodClose
Close first leave the Membership gracefully and then call shutdown.
pkg/raftcluster/membership.go:109
↓ 2 callersMethodClose
(ctx context.Context)
cmd/unisondb/cliapp/service_raft.go:503
↓ 2 callersMethodClose
(ctx context.Context)
cmd/unisondb/cliapp/service_blob_store_streamer.go:120
↓ 2 callersMethodClose
(ctx context.Context)
cmd/unisondb/cliapp/service_pprof.go:85
↓ 2 callersMethodClose
(ctx context.Context)
cmd/unisondb/cliapp/service_grpc.go:172
↓ 2 callersFunctionColumnDataAddName
(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/ColumnData.go:89
↓ 2 callersFunctionColumnDataAddValue
(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/ColumnData.go:92
↓ 2 callersFunctionColumnDataEnd
(builder *flatbuffers.Builder)
internal/benchtests/serialization/logrecord/ColumnData.go:98
↓ 2 callersFunctionColumnDataStart
(builder *flatbuffers.Builder)
internal/benchtests/serialization/logrecord/ColumnData.go:86
↓ 2 callersMethodCrc32Checksum
()
schemas/logrecord/LogRecord.go:68
↓ 2 callersMethodCurrentSegmentInfo
CurrentSegmentInfo returns the last LSN and offset from the current segment's metadata.
dbkernel/internal/wal/wal.go:471
↓ 2 callersMethodDeleteKV
(key []byte)
pkg/kvdrivers/api.go:18
↓ 2 callersFunctionDetermineChunkType
(start, end, totalSize int)
pkg/splitter/chunk.go:50
↓ 2 callersMethodEnabled
(_ context.Context, level slog.Level)
pkg/logutil/percentage_logger.go:25
↓ 2 callersMethodEnabled
()
cmd/unisondb/cliapp/service_pprof.go:100
↓ 2 callersMethodEnabled
()
cmd/unisondb/cliapp/service_fuzzer.go:113
↓ 2 callersMethodEnabled
()
cmd/unisondb/cliapp/service_grpc.go:188
↓ 2 callersMethodEntries
(obj *RowUpdateEncoded, j int)
internal/benchtests/serialization/logrecord/RowUpdateEntries.go:44
↓ 2 callersMethodEntriesLength
()
internal/benchtests/serialization/logrecord/RowUpdateEntries.go:56
↓ 2 callersFunctionEventEntryAddEventId
(builder *flatbuffers.Builder, eventId flatbuffers.UOffsetT)
schemas/logrecord/EventEntry.go:129
↓ 2 callersFunctionEventEntryAddEventType
(builder *flatbuffers.Builder, eventType flatbuffers.UOffsetT)
schemas/logrecord/EventEntry.go:132
↓ 2 callersFunctionEventEntryAddOccurredAt
(builder *flatbuffers.Builder, occurredAt uint64)
schemas/logrecord/EventEntry.go:135
↓ 2 callersFunctionEventEntryEnd
(builder *flatbuffers.Builder)
schemas/logrecord/EventEntry.go:150
↓ 2 callersFunctionEventEntryStart
(builder *flatbuffers.Builder)
schemas/logrecord/EventEntry.go:126
↓ 2 callersMethodFetchValue
FetchValue fetches the current value for a key from the specified namespace. It then processes the update through the state manager.
cmd/examples/crdt-multi-dc/golang-crdt-client/client/http_client.go:39
↓ 2 callersMethodFlushedTerm
FlushedTerm returns the last Raft log term flushed to B-tree.
dbkernel/engine_raft.go:406
↓ 2 callersMethodGen
()
internal/benchtests/cmd/genclient/gen/gen.go:56
↓ 2 callersMethodGetCluster
(namespace string)
cmd/unisondb/cliapp/service_raft.go:583
↓ 2 callersMethodGetLastOffset
()
dbkernel/internal/memtable/memtable.go:137
↓ 2 callersFunctionGetRootAsLogRecord
(buf []byte, offset flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/LogRecord.go:13
↓ 2 callersFunctionGetRootAsRowUpdateEntry
(buf []byte, offset flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/RowUpdateEntry.go:13
↓ 2 callersMethodGetState
GetState returns the current state of the counter.
cmd/examples/crdt-multi-dc/golang-crdt-client/crdt/g_counter.go:51
↓ 2 callersMethodGetWalCheckPoint
GetWalCheckPoint returns the last checkpoint metadata saved in the database.
dbkernel/engine_public.go:228
↓ 2 callersFunctionGetWalRecord
GetWalRecord returns the underlying wal record.
dbkernel/internal/utils.go:39
↓ 2 callersMethodHandle
(ctx context.Context, r slog.Record)
pkg/logutil/percentage_logger.go:37
↓ 2 callersMethodHandleConn
(ctx context.Context, connStats stats.ConnStats)
internal/grpcutils/stats_handler.go:222
↓ 2 callersMethodID
ID returns the codec identifier.
pkg/raftwalfs/codec.go:43
↓ 2 callersMethodIncrOffset
()
dbkernel/internal/memtable/memtable.go:129
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/KeyValueEncoded.go:35
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/KeyValueEntry.go:35
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/RowUpdateEncoded.go:35
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/LogRecord.go:35
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
internal/benchtests/serialization/logrecord/ColumnData.go:35
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
schemas/logrecord/KeyValueEntry.go:35
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
schemas/logrecord/ColumnData.go:35
↓ 2 callersMethodInit
(buf []byte, i flatbuffers.UOffsetT)
schemas/logrecord/EncodedEntry.go:35
↓ 2 callersMethodInitializePartition
(ctx context.Context, partition uint32, nextLSN uint64)
internal/services/streamer/blob_store_steamer_internal_test.go:277
↓ 2 callersFunctionIsActive
(flags uint32)
pkg/walfs/segment.go:598
↓ 2 callersMethodIsClosed
()
pkg/raftmux/stream_layer.go:93
↓ 2 callersMethodKey
(j int)
schemas/logrecord/KeyValueEntry.go:44
↓ 2 callersFunctionKeyColumn
KeyColumn returns the storage key for a wide-column cell.
internal/keycodec/keycodec.go:98
↓ 2 callersFunctionKeyValueEntryAddKey
(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
schemas/logrecord/KeyValueEntry.go:115
↓ 2 callersFunctionKeyValueEntryAddValue
(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
schemas/logrecord/KeyValueEntry.go:121
↓ 2 callersFunctionKeyValueEntryEnd
(builder *flatbuffers.Builder)
schemas/logrecord/KeyValueEntry.go:127
↓ 2 callersFunctionKeyValueEntryStart
(builder *flatbuffers.Builder)
schemas/logrecord/KeyValueEntry.go:112
↓ 2 callersMethodLastRecordPosition
LastRecordPosition returns the RecordPosition of the last successfully read entry.
pkg/walfs/walog.go:1395
← previousnext →601–700 of 3,181, ranked by callers