MCPcopy Create free account

hub / github.com/Shopify/ghostferry / functions

Functions1,224 in github.com/Shopify/ghostferry

⨍ Functions 1,224◇ Types & classes 176
MethodMain
=========================================== Code to handle an almost standard Ferry run ===========================================
test/lib/go/integrationferry/ferry.go:111
MethodMarshalJSON
()
state_tracker.go:45
MethodMessage
()
inline_verifier.go:323
MethodMessage
()
verifier.go:246
MethodMessage
()
iterative_verifier.go:284
MethodNewBinlogWriterWithoutStateTracker
()
ferry.go:181
MethodNewValues
()
dml_events.go:166
MethodNewValues
()
dml_events.go:220
MethodNewValues
()
dml_events.go:249
MethodNewValues
()
test/go/binlog_writer_test.go:23
MethodOldValues
()
dml_events.go:162
MethodOldValues
()
dml_events.go:216
MethodOldValues
()
dml_events.go:245
MethodOldValues
()
test/go/binlog_writer_test.go:22
FunctionOpen
(driverName, dataSourceName, marginalia string)
sqlwrapper/ghostferry_db.go:19
MethodPaginationKey
()
dml_events.go:183
MethodPaginationKey
()
dml_events.go:236
MethodPaginationKey
()
dml_events.go:277
MethodPaginationKey
()
test/go/binlog_writer_test.go:24
MethodPanicf
(format string, args ...any)
zerolog_logger.go:83
MethodPanicf
(format string, args ...any)
logrus_logger.go:22
MethodPrepare
(query string)
sqlwrapper/ghostferry_db.go:40
MethodPrepare
(query string)
sqlwrapper/ghostferry_db.go:78
MethodPrepareContext
(ctx context.Context, query string)
sqlwrapper/ghostferry_db.go:82
MethodQuery
(query string, args ...interface{})
sqlwrapper/ghostferry_db.go:90
MethodQueryContext
(ctx context.Context, query string, args ...interface{})
sqlwrapper/ghostferry_db.go:86
MethodQueryRow
(query string, args ...interface{})
sqlwrapper/ghostferry_db.go:98
MethodQueryRowContext
(ctx context.Context, query string, args ...interface{})
sqlwrapper/ghostferry_db.go:94
MethodReportError
(from string, err error)
testhelpers/error_handler.go:7
MethodResult
()
inline_verifier.go:327
MethodResult
()
verifier.go:254
MethodResult
()
iterative_verifier.go:288
MethodResumableBinlogPosition
()
dml_events.go:111
MethodResumableBinlogPosition
()
test/go/binlog_writer_test.go:26
MethodRollback
()
cursor.go:24
FunctionRun
(f *IntegrationFerry)
test/lib/go/integrationferry/ferry.go:265
MethodRun
()
binlog_streamer.go:238
MethodRun
(tables []*TableSchema)
data_iterator.go:31
MethodRun
()
control_server.go:131
MethodRun
(ctx context.Context)
throttler.go:69
MethodRun
(ctx context.Context)
throttler.go:131
MethodRun
()
binlog_writer.go:38
MethodRun
()
testhelpers/test_ferry.go:113
MethodRun
()
copydb/copydb.go:66
MethodRun
()
sharding/sharding.go:123
MethodRun
()
sharding/test/trivial_integration_test.go:124
MethodSerialize
()
inline_verifier.go:234
MethodServeHTTP
(w http.ResponseWriter, r *http.Request)
control_server.go:140
MethodSetDB
(db *sql.DB)
sharding/test/trivial_integration_test.go:131
MethodSetDisabled
(disabled bool)
throttler.go:44
MethodSetPaused
(paused bool)
throttler.go:61
FunctionSetup
(c *RunCallbacks)
test/lib/go/integrationferry/ferry.go:344
MethodSetupSuite
()
sharding/testhelpers/unit_test_suite.go:45
MethodSetupTest
()
testhelpers/unit_test_suite.go:64
MethodSetupTest
()
test/go/table_schema_cache_test.go:42
MethodSetupTest
()
test/go/data_iterator_sorter_test.go:39
MethodSetupTest
()
test/go/config_test.go:19
MethodSetupTest
()
test/go/ferry_test.go:17
MethodSetupTest
()
test/go/utils_test.go:19
MethodSetupTest
()
test/go/metrics_test.go:19
MethodSetupTest
()
test/go/logger_test.go:68
MethodSetupTest
()
test/go/iterative_verifier_test.go:26
MethodSetupTest
()
test/go/iterative_verifier_collation_test.go:21
MethodSetupTest
()
test/go/binlog_streamer_test.go:26
MethodSetupTest
()
test/go/dml_events_test.go:24
MethodSetupTest
()
test/go/row_batch_test.go:21
MethodSetupTest
()
test/go/throttler_test.go:18
MethodSetupTest
()
test/go/wait_until_replica_is_caught_up_to_master_test.go:21
MethodSetupTest
()
test/go/verifier_test.go:20
MethodSetupTest
()
test/go/replication_config_test.go:21
MethodSetupTest
()
test/go/data_iterator_test.go:23
MethodSetupTest
()
copydb/test/copydb_test.go:28
MethodSetupTest
()
copydb/test/filter_test.go:20
MethodSetupTest
()
sharding/testhelpers/unit_test_suite.go:70
MethodSetupTest
()
sharding/test/copy_filter_test.go:28
MethodSetupTest
()
sharding/test/joined_tables_test.go:20
MethodSetupTest
()
sharding/test/primary_key_table_test.go:19
MethodSetupTest
()
sharding/test/callbacks_test.go:22
MethodSort
(unorderedTables map[*TableSchema]PaginationKey)
data_iterator_sorter.go:11
MethodStart
()
copydb/copydb.go:39
MethodStartInBackground
This is called from the control server, which is triggered by pushing Run Verification during cutover. This step is necessary to ensure the binlogs ar
inline_verifier.go:288
MethodStartInBackground
()
verifier.go:211
MethodStartInBackground
()
iterative_verifier.go:244
MethodStop
()
sharding/test/trivial_integration_test.go:128
MethodTable
()
dml_events.go:99
MethodTable
()
test/go/binlog_writer_test.go:19
MethodTableSchema
()
dml_events.go:103
MethodTableSchema
()
test/go/binlog_writer_test.go:20
MethodTearDownSuite
()
sharding/testhelpers/unit_test_suite.go:66
MethodTearDownTest
()
testhelpers/unit_test_suite.go:83
MethodTearDownTest
()
test/go/table_schema_cache_test.go:56
MethodTearDownTest
()
test/go/data_iterator_sorter_test.go:66
MethodTearDownTest
()
test/go/logger_test.go:72
MethodTearDownTest
()
test/go/iterative_verifier_test.go:61
MethodTearDownTest
()
test/go/iterative_verifier_collation_test.go:41
MethodTearDownTest
()
test/go/replication_config_test.go:38
MethodTearDownTest
()
copydb/test/copydb_test.go:64
MethodTearDownTest
()
sharding/testhelpers/unit_test_suite.go:118
MethodTearDownTest
()
sharding/test/joined_tables_test.go:47
MethodTearDownTest
()
sharding/test/primary_key_table_test.go:26
← previousnext →601–700 of 1,224, ranked by callers