Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/alibaba/MongoShake
/ functions
Functions
933 in github.com/alibaba/MongoShake
⨍
Functions
933
◇
Types & classes
171
Method
LTE
(v2 Version)
tools/pre-split/pre_split.go:77
Method
Less
(i, j int)
common/mix.go:27
Method
Link
(replayer []Replayer)
tunnel/kafka_reader.go:17
Method
Link
(relativeReplayer []Replayer)
tunnel/file_reader.go:21
Method
Link
(replayer []Replayer)
tunnel/tcp_reader.go:29
Method
Link
(replayer []Replayer)
tunnel/mock_reader.go:32
Method
Link
(replayers []Replayer)
tunnel/rpc_reader.go:17
Function
LogFetchStage
(stage int32)
common/diskQueue.go:12
Function
MarshalData
(input bson.D)
common/parse.go:41
Function
MayBeRandom
(port int)
common/mix.go:123
Method
Name
()
modules/compress.go:144
Method
Name
()
modules/compress.go:181
Method
Name
()
modules/compress.go:206
Method
Name
()
modules/compress.go:244
Method
Name
()
collector/reader/oplog_reader.go:81
Method
Name
()
collector/reader/event_reader.go:63
Method
Name
()
collector/coordinator/extra_job.go:25
Method
Name
()
tunnel/file_writer.go:88
Method
Name
()
tunnel/mock_writer.go:12
Method
Name
()
tunnel/tcp_writer.go:155
Method
Name
()
tunnel/direct_writer.go:18
Method
Name
()
tunnel/rpc_writer.go:20
Method
Name
()
tunnel/kafka_writer.go:49
Function
NewNS
(namespace string)
common/session.go:26
Function
NewSentinel
(tp string)
common/sentinel.go:46
Method
NextOplog
NextOplog returns an oplog by oplog.GenericOplog struct
collector/reader/oplog_reader.go:110
Method
ParsedLogsRequired
()
tunnel/file_writer.go:166
Method
ParsedLogsRequired
()
tunnel/mock_writer.go:33
Method
ParsedLogsRequired
()
tunnel/tcp_writer.go:249
Method
ParsedLogsRequired
()
tunnel/direct_writer.go:52
Method
ParsedLogsRequired
()
tunnel/rpc_writer.go:84
Method
ParsedLogsRequired
** * whether need parsed log or raw log */
tunnel/tunnel.go:145
Method
ParsedLogsRequired
()
tunnel/kafka_writer.go:108
Method
Prepare
()
tunnel/file_writer.go:139
Method
Prepare
()
tunnel/mock_writer.go:25
Method
Prepare
()
tunnel/tcp_writer.go:220
Method
Prepare
()
tunnel/direct_writer.go:22
Method
Prepare
()
tunnel/rpc_writer.go:55
Method
Print
(args ...any)
pkg/log/logger.go:183
Function
PrometheusInitHttpApi
(port int)
common/http.go:29
Method
RestAPI
()
collector/persister.go:315
Method
Run
()
collector/coordinator/replication.go:41
Method
Run
()
collector/coordinator/extra_job.go:131
Method
Send
(logs []*oplog.GenericOplog, tag uint32)
collector/write_controller.go:91
Method
Send
(message *WMessage)
tunnel/file_writer.go:92
Method
Send
(message *WMessage)
tunnel/mock_writer.go:16
Method
Send
(message *WMessage)
tunnel/tcp_writer.go:198
Method
Send
(message *WMessage)
tunnel/direct_writer.go:42
Method
Send
(message *WMessage)
tunnel/rpc_writer.go:24
Function
SetFiled
(input bson.D, key string, value interface{}, upsert bool)
common/parse.go:27
Method
SetInitSyncFinishTs
set init sync finish timestamp if tunnel is direct
collector/write_controller.go:72
Method
SetQueryTimestampOnEmpty
SetQueryTimestampOnEmpty set internal timestamp if not exist in this or. initial stage most of the time
collector/reader/oplog_reader.go:87
Method
SetQueryTimestampOnEmpty
SetQueryTimestampOnEmpty set internal timestamp if not exist in this or. initial stage most of the time
collector/reader/event_reader.go:69
Method
Start
()
collector/persister.go:66
Method
Start
()
executor/executor.go:59
Method
StartFetcher
StartFetcher start fetcher if not exist
collector/reader/oplog_reader.go:135
Function
StartQoS
(limit, ticket int64, addr *int64)
common/speed.go:21
Method
Step
(challenge string)
tunnel/kafka/saram_client.go:30
Method
String
()
collector/syncer.go:184
Method
String
()
collector/worker.go:65
Method
String
()
collector/docsyncer/doc_reader.go:96
Method
String
()
collector/docsyncer/doc_syncer.go:373
Method
String
()
collector/docsyncer/metric.go:25
Method
String
()
collector/docsyncer/doc_executor.go:153
Method
String
()
collector/ckpt/ckpt_operation.go:37
Method
String
()
oplog/txn_meta.go:28
Method
String
()
oplog/txn_meta.go:136
Method
String
()
oplog/oplog.go:101
Method
String
()
oplog/txn_optime.go:94
Method
String
()
oplog/change_stream_event.go:89
Method
String
()
common/metric.go:109
Method
String
()
common/db_opertion.go:45
Method
String
()
tunnel/tcp_writer.go:115
Method
String
()
tunnel/tunnel.go:102
Method
String
()
tunnel/kafka_writer.go:112
Method
Swap
(i, j int)
common/mix.go:30
Method
Sync
(docs []*bson.Raw)
collector/docsyncer/doc_executor.go:90
Method
Sync
(rawLogs []*oplog.PartialLog, callback func())
executor/executor.go:77
Method
TableOps
()
common/metric.go:319
Function
TestAutologousFilter
(t *testing.T)
collector/filter/filter_test.go:1033
Function
TestBatchMore
(t *testing.T)
collector/batcher_test.go:804
Function
TestBatchMoreApplyOpsInheritsSourceTime
(t *testing.T)
collector/batcher_test.go:708
Function
TestBlockMongoUrlPassword
(t *testing.T)
common/common_test.go:17
Function
TestBulkWriter
(t *testing.T)
executor/db_writer_test.go:500
Function
TestCalculateTop3
(t *testing.T)
executor/executor_test.go:644
Function
TestCalculateWorkerLowestCheckpoint
(t *testing.T)
collector/checkpoint_test.go:22
Function
TestChangeStreamConn
(t *testing.T)
common/change_stream_test.go:16
Function
TestCheckConflictRejectPrometheusHTTPPortConflict
(t *testing.T)
cmd/collector/sanitize_test.go:107
Function
TestCheckConflictRejectPrometheusSystemProfilePortConflict
(t *testing.T)
cmd/collector/sanitize_test.go:124
Function
TestCheckDefaultValueAcceptMasterQuorumElectionID
(t *testing.T)
cmd/collector/sanitize_test.go:90
Function
TestCheckDefaultValueInvalidFilterOpTypes
(t *testing.T)
cmd/collector/sanitize_test.go:24
Function
TestCheckDefaultValueKeepDisabledHTTPPorts
(t *testing.T)
cmd/collector/sanitize_test.go:38
Function
TestCheckDefaultValueRejectInvalidMasterQuorumElectionID
(t *testing.T)
cmd/collector/sanitize_test.go:73
Function
TestCheckDefaultValueRequireMasterQuorumElectionID
(t *testing.T)
cmd/collector/sanitize_test.go:58
Function
TestCheckFcv
(t *testing.T)
collector/configure/check_test.go:13
Function
TestCheckIndexKeyTypeConsistency
TestCheckIndexKeyTypeConsistency tests the type consistency check for parallel split.
collector/docsyncer/doc_syncer_test.go:528
Function
TestCommandWriter
(t *testing.T)
executor/db_writer_test.go:995
Function
TestCommonFunctions
(t *testing.T)
common/community_client_test.go:21
Function
TestComputeHash
only for print
collector/filter/filter_test.go:1395
Function
TestConvertBson
(t *testing.T)
oplog/oplog_test.go:463
← previous
next →
701–800 of 933, ranked by callers