MCPcopy Create free account

hub / github.com/Shopify/ghostferry / functions

Functions1,224 in github.com/Shopify/ghostferry

⨍ Functions 1,224◇ Types & classes 176
↓ 1 callersMethodpaginationKeyColumn
(cascadingPaginationColumnConfig *CascadingPaginationColumnConfig)
table_schema_cache.go:264
↓ 1 callersFunctionparseConfig
()
sharding/cmd/main.go:74
↓ 1 callersFunctionpostCallback
(client *http.Client, uri string, body interface{})
http_callback.go:26
↓ 1 callersFunctionquotedColumnNames
(table *TableSchema)
dml_events.go:326
↓ 1 callersFunctionrandUnicodeRune
()
testhelpers/data_writer.go:50
↓ 1 callersFunctionrandomServerId
()
utils.go:60
↓ 1 callersMethodremove_all_binaries
test/helpers/ghostferry_helper.rb:13
↓ 1 callersMethodreset
test/test_helper.rb:49
↓ 1 callersMethodreverifyPaginationKeys
(table *TableSchema, paginationKeys []interface{})
iterative_verifier.go:515
↓ 1 callersMethodreverifyUntilStoreIsSmallEnough
(maxIterations int)
iterative_verifier.go:332
↓ 1 callersFunctionrightPadBufferWithZeroBytes
(buffer []byte, padLength int)
dml_events.go:535
↓ 1 callersFunctionrowMd5Selector
(columns []schema.TableColumn, paginationKeyColumn string)
iterative_verifier.go:677
↓ 1 callersFunctionrowSelector
(columns []schema.TableColumn, paginationKeyColumn string)
compression_verifier.go:262
↓ 1 callersMethodrun_ghostferry
(ghostferry_config:, output_dir:, duration: 15)
benchmark/ghostferry_benchmark.rb:151
↓ 1 callersFunctionsaveLogState
()
test/go/logger_test.go:27
↓ 1 callersFunctionscriptName
(r *http.Request)
control_server.go:427
↓ 1 callersFunctionsetLogrusJSONFormatter
()
logrus_logger.go:67
↓ 1 callersFunctionsetLogrusLevel
(level LogLevel)
logrus_logger.go:54
↓ 1 callersFunctionsetLogrusOutput
(w io.Writer)
logrus_logger.go:71
↓ 1 callersFunctionsetZerologJSONFormatter
()
zerolog_logger.go:148
↓ 1 callersFunctionsetZerologLevel
(level LogLevel)
zerolog_logger.go:135
↓ 1 callersFunctionsetZerologOutput
(w io.Writer)
zerolog_logger.go:152
↓ 1 callersMethodsetupShardingFerry
()
sharding/testhelpers/unit_test_suite.go:134
↓ 1 callersMethodshardingKeyIndexHint
(table *ghostferry.TableSchema, indexHint string)
sharding/filter.go:142
↓ 1 callersMethodshardingKeyIndexName
(table *ghostferry.TableSchema)
sharding/filter.go:161
↓ 1 callersFunctionshowDatabases
(c *sql.DB)
table_schema_cache.go:375
↓ 1 callersFunctionshowTablesFrom
(c *sql.DB, dbname string)
table_schema_cache.go:401
↓ 1 callersMethodstart
benchmark/ghostferry_benchmark.rb:34
↓ 1 callersMethodstartScriptInBackground
(scriptName string, scriptCmd []string)
control_server.go:457
↓ 1 callersMethodstop
benchmark/ghostferry_benchmark.rb:42
↓ 1 callersMethodstoreStmt
(query string, stmt *sqlorig.Stmt)
utils.go:178
↓ 1 callersMethodupdateLag
(ctx context.Context)
throttler.go:149
↓ 1 callersMethodupdateLastStreamedPosAndTime
(evTimestamp uint32, evPos mysql.Position, evType string, isResumablePosition bool)
binlog_streamer.go:368
↓ 1 callersMethodupdateRowStatsForTable
(table string, rowStats RowStats)
state_tracker.go:288
↓ 1 callersMethodupdateSpeedLog
(deltaPaginationKey float64)
state_tracker.go:295
↓ 1 callersFunctionusage
()
copydb/cmd/main.go:13
↓ 1 callersMethodverifyBinlogBatch
Returns a list of mismatched PaginationKeys. Since the mismatches gets re-added to the reverify store, this must return a union of mismatches of finge
inline_verifier.go:811
↓ 1 callersMethodverifyConfiguredCompression
(tableColumnCompressions TableColumnCompressionConfig)
compression_verifier.go:197
↓ 1 callersMethodverifyTableChecksum
()
testhelpers/integration_test_case.go:164
↓ 1 callersMethodwaitUntilAutomaticCutoverIsTrue
()
ferry.go:1090
↓ 1 callersMethodwipe_target
benchmark/ghostferry_benchmark.rb:101
↓ 1 callersMethodwriteEvents
(events []DMLEvent)
binlog_writer.go:90
↓ 1 callersFunctionzerologWithError
(err error)
zerolog_logger.go:121
↓ 1 callersFunctionzerologWithField
--- internal factory functions (called by logger.go dispatch) ---
zerolog_logger.go:103
↓ 1 callersFunctionzerologWithFields
(fields Fields)
zerolog_logger.go:110
FunctionAfterInitialize
(f *tf.IntegrationFerry)
test/lib/go/ddl_ghostferry/main.go:16
MethodAnnotation
Annotation will return the first prefixed comment on the SQL string, or an error if the query attribute of the DMLEvent is not set
dml_events.go:117
MethodAnnotation
()
test/go/binlog_writer_test.go:27
MethodApplicableDatabases
(dbs []string)
testhelpers/test_table_filter.go:10
MethodApplicableEvent
(event ghostferry.DMLEvent)
sharding/filter.go:195
MethodApplicableTables
(tables []*ghostferry.TableSchema)
testhelpers/test_table_filter.go:18
MethodAsSQLString
(schemaName, tableName string)
dml_events.go:170
MethodAsSQLString
(schemaName, tableName string)
dml_events.go:224
MethodAsSQLString
(schemaName, tableName string)
dml_events.go:266
MethodAsSQLString
(_, _ string)
test/go/binlog_writer_test.go:21
MethodBinlogEventListener
Verify that all DMLs against the target are coming from Ghostferry for the duration of the move. Once cutover has completed, we no longer need to perf
target_verifier.go:31
MethodBinlogPosition
()
dml_events.go:107
MethodBinlogPosition
()
test/go/binlog_writer_test.go:25
MethodBuildSelect
(columns []string, table *ghostferry.TableSchema, lastPaginationKey ghostferry.PaginationKey, batchSize uint64
sharding/filter.go:35
MethodColumnName
()
pagination_key.go:57
MethodColumnName
()
pagination_key.go:122
MethodCurrent
(replicaDB *sql.DB)
wait_until_replica_is_caught_up_to_master.go:35
MethodDatabase
()
dml_events.go:95
MethodDatabase
()
test/go/binlog_writer_test.go:18
MethodDebug
(args ...any)
zerolog_logger.go:75
MethodDebug
(args ...any)
logrus_logger.go:14
MethodDebugf
(format string, args ...any)
zerolog_logger.go:76
MethodDebugf
(format string, args ...any)
logrus_logger.go:15
MethodDeleteRow
(id int)
test/go/iterative_verifier_test.go:345
MethodDisabled
()
throttler.go:40
MethodEnabled
Enabled always returns true; the ghostferry Logger backend filters by level.
slog_handler.go:25
MethodError
()
verifier.go:15
MethodError
()
verifier.go:25
MethodError
()
batch_writer.go:24
MethodError
(args ...any)
zerolog_logger.go:81
MethodError
(args ...any)
logrus_logger.go:20
MethodError
()
compression_verifier.go:39
MethodErrorf
(format string, args ...any)
zerolog_logger.go:82
MethodErrorf
(format string, args ...any)
logrus_logger.go:21
MethodExec
(query string, args ...interface{})
sqlwrapper/ghostferry_db.go:74
MethodExecContext
(ctx context.Context, query string, args ...interface{})
sqlwrapper/ghostferry_db.go:70
MethodFatal
(from string, err error)
error_handler.go:69
MethodGet
(database, table string)
table_schema_cache.go:333
MethodGetLastStreamedBinlogPosition
()
binlog_streamer.go:339
MethodHandle
Handle converts a slog.Record into a ghostferry Logger call. Attributes from both WithAttrs and the record itself are applied via WithField so they ap
slog_handler.go:32
MethodHandleConfigGet
(w http.ResponseWriter, r *http.Request)
control_server.go:370
MethodHandleConfigPost
(w http.ResponseWriter, r *http.Request)
control_server.go:378
MethodHandleCutover
(w http.ResponseWriter, r *http.Request)
control_server.go:173
MethodHandleIndex
(w http.ResponseWriter, r *http.Request)
control_server.go:152
MethodHandlePause
(w http.ResponseWriter, r *http.Request)
control_server.go:161
MethodHandleScript
(w http.ResponseWriter, r *http.Request)
control_server.go:348
MethodHandleStatus
(w http.ResponseWriter, r *http.Request)
control_server.go:211
MethodHandleStop
(w http.ResponseWriter, r *http.Request)
control_server.go:192
MethodHandleUnpause
(w http.ResponseWriter, r *http.Request)
control_server.go:167
MethodHandleVerify
(w http.ResponseWriter, r *http.Request)
control_server.go:196
MethodInfo
(args ...any)
zerolog_logger.go:77
MethodInfo
(args ...any)
logrus_logger.go:16
MethodInfof
(format string, args ...any)
zerolog_logger.go:78
MethodInfof
(format string, args ...any)
logrus_logger.go:17
MethodIsMax
()
pagination_key.go:83
← previousnext →501–600 of 1,224, ranked by callers