MCPcopy Create free account

hub / github.com/Shopify/ghostferry / functions

Functions1,224 in github.com/Shopify/ghostferry

⨍ Functions 1,224◇ Types & classes 176
↓ 1 callersMethodNewControlServer
()
ferry.go:253
↓ 1 callersMethodNewCursorWithoutRowLock
returns a new Cursor with an embedded copy of itself
cursor.go:60
↓ 1 callersMethodNewDataIteratorWithoutStateTracker
()
ferry.go:122
↓ 1 callersMethodNewInlineVerifierWithoutStateTracker
()
ferry.go:269
↓ 1 callersMethodNewIterativeVerifier
()
ferry.go:275
↓ 1 callersFunctionNewShardedCopyFilter
(config *Config)
sharding/sharding.go:84
↓ 1 callersMethodNewSourceBinlogStreamer
()
ferry.go:128
↓ 1 callersFunctionNewStandardConfig
()
test/lib/go/integrationferry/ferry.go:178
↓ 1 callersFunctionNewStateTrackerFromSerializedState
serializedState is a state the tracker should start from, as opposed to starting from the beginning.
state_tracker.go:165
↓ 1 callersFunctionNewTableIdentifierFromSchemaTable
(table *TableSchema)
table_schema_cache.go:28
↓ 1 callersMethodNewTargetBinlogStreamer
()
ferry.go:132
↓ 1 callersFunctionNewTargetVerifier
(targetDB *sql.DB, stateTracker *StateTracker, binlogStreamer *BinlogStreamer)
target_verifier.go:16
↓ 1 callersFunctionNonBinaryCollationError
NonBinaryCollationError exported to facilitate black box testing
table_schema_cache.go:260
↓ 1 callersFunctionNonNumericPaginationKeyError
NonNumericPaginationKeyError exported to facilitate black box testing
table_schema_cache.go:255
↓ 1 callersMethodNumericPosition
()
pagination_key.go:75
↓ 1 callersMethodPaginationColumnFor
PaginationColumnFor is a helper function to retrieve the column name to paginate by
config.go:393
↓ 1 callersMethodPeriodicallyVerifyBinlogEvents
(ctx context.Context)
inline_verifier.go:393
↓ 1 callersMethodPrepareContext
(ctx context.Context, query string)
sqlwrapper/ghostferry_db.go:24
↓ 1 callersFunctionProcessListContainsQueries
(db *sql.DB, queries []string)
testhelpers/helper_methods.go:21
↓ 1 callersMethodQueryContext
(ctx context.Context, query string, args ...interface{})
sqlwrapper/ghostferry_db.go:32
↓ 1 callersFunctionQuoteFields
(fields []string)
utils.go:269
↓ 1 callersFunctionRandByteData
RandByteData returns a slice of random bytes
testhelpers/data_writer.go:24
↓ 1 callersFunctionRandLatin1Data
RandLatin1Data returns a UTF-8 string with valid codepoints for a latin1 charset
testhelpers/data_writer.go:42
↓ 1 callersFunctionRandUTF8MB4Data
RandUTF8MB4Data returns a UTF-8 string with valid codepoints up to U+10FFFF
testhelpers/data_writer.go:33
↓ 1 callersMethodRemoveVerifiedBatch
(batch BinlogVerifyBatch)
inline_verifier.go:160
↓ 1 callersMethodReportError
(from string, err error)
error_handler.go:25
↓ 1 callersMethodReportState
ReportState may have a slight performance impact as it will temporarily lock the StateTracker when it is serialized before posting to the callback
ferry.go:1075
↓ 1 callersMethodRowStatsWrittenPerTable
()
state_tracker.go:217
↓ 1 callersMethodRun
()
testhelpers/data_writer.go:126
↓ 1 callersMethodSQLValue
()
pagination_key.go:53
↓ 1 callersMethodSQLValue
()
pagination_key.go:118
↓ 1 callersMethodSanityCheckParameters
()
iterative_verifier.go:147
↓ 1 callersMethodSeedTargetDB
(numberOfRows int)
testhelpers/unit_test_suite.go:73
↓ 1 callersMethodSetColumnType
(schema, table, column, columnType string, db *sql.DB)
test/go/iterative_verifier_test.go:323
↓ 1 callersMethodSetDB
(db *sql.DB)
testhelpers/data_writer.go:146
↓ 1 callersFunctionSetGlobalMetrics
(prefix string, sink chan interface{})
metrics.go:35
↓ 1 callersMethodSetReadonlyOnSourceDbAndStopDataWriter
()
testhelpers/integration_test_case.go:91
↓ 1 callersMethodSetupTest
()
test/go/iterative_verifier_test.go:400
↓ 1 callersMethodSort
(unorderedTables map[*TableSchema]PaginationKey)
data_iterator_sorter.go:17
↓ 1 callersMethodStart
()
testhelpers/test_ferry.go:80
↓ 1 callersMethodStartFerryAndDataWriter
()
testhelpers/integration_test_case.go:62
↓ 1 callersMethodStop
()
binlog_writer.go:78
↓ 1 callersMethodStop
()
testhelpers/data_writer.go:142
↓ 1 callersMethodStopAndFlush
()
metrics.go:105
↓ 1 callersFunctionStopAndFlushMetrics
()
sharding/metrics.go:43
↓ 1 callersMethodStopStreamingAndWaitForGhostferryFinish
()
testhelpers/integration_test_case.go:101
↓ 1 callersMethodString
()
pagination_key.go:79
↓ 1 callersMethodString
()
pagination_key.go:155
↓ 1 callersMethodTestCreateDatabaseAndTableWithRewrites
()
copydb/test/copydb_test.go:73
↓ 1 callersMethodUpdateData
()
testhelpers/data_writer.go:204
↓ 1 callersMethodUpdateLastSuccessfulPaginationKey
(table string, paginationKey PaginationKey, rowStats RowStats)
state_tracker.go:196
↓ 1 callersMethodVerifyData
()
testhelpers/integration_test_case.go:111
↓ 1 callersMethodVerifyDuringCutover
()
inline_verifier.go:500
↓ 1 callersMethodVerifyDuringCutover
()
verifier.go:115
↓ 1 callersMethodWithGroup
WithGroup returns a new handler that nests all subsequent attribute keys under the given group name, using a dot separator (e.g. "db.host").
slog_handler.go:72
↓ 1 callersMethodWriteData
(i int)
testhelpers/data_writer.go:150
↓ 1 callersFunctionadd_to_load_path
(path)
test/test_helper.rb:14
↓ 1 callersFunctionannotate
(queries []string, marginalia string)
test/go/race_conditions_integration_test.go:20
↓ 1 callersFunctionbuildStringListForValues
(columns []schema.TableColumn, values []interface{})
dml_events.go:350
↓ 1 callersFunctionbuildStringMapForSet
(columns []schema.TableColumn, values []interface{})
dml_events.go:386
↓ 1 callersMethodcheckConnectionForBinlogFormat
(db *sql.DB)
ferry.go:1130
↓ 1 callersMethodcheckForDeprecatedConfig
()
config.go:911
↓ 1 callersMethodcheckSourceForeignKeyConstraints
()
ferry.go:1168
↓ 1 callersMethodcompareCompressedHashes
(targetDb, targetTable string, table *TableSchema, paginationKeys []interface{})
iterative_verifier.go:629
↓ 1 callersMethodcompareHashes
(source, target map[string][]byte)
inline_verifier.go:624
↓ 1 callersFunctionconsumeMetrics
(client *statsd.Client, metricsChan chan interface{})
sharding/metrics.go:47
↓ 1 callersMethodcopyPrimaryKeyTables
()
sharding/sharding.go:206
↓ 1 callersMethodcreateBinlogSyncer
()
binlog_streamer.go:76
↓ 1 callersMethodcreateDatabaseIfExistsOnTarget
(database string)
copydb/copydb.go:137
↓ 1 callersMethodcreateTableOnTarget
(database, table string)
copydb/copydb.go:163
↓ 1 callersFunctioncutoverType
(r *http.Request)
control_server.go:395
↓ 1 callersMethoddefaultEventHandler
the default event handler is called for replication binLogEvents that do not have a separate event Handler registered.
binlog_streamer.go:154
↓ 1 callersMethoddefault_ghostferry_config
benchmark/ghostferry_benchmark.rb:108
↓ 1 callersFunctiondeleteTestRowsToTriggerFailure
(ferry *testhelpers.TestFerry)
test/go/iterative_verifier_integration_test.go:292
↓ 1 callersMethoddeltaCopyJoinedTables
()
sharding/sharding.go:189
↓ 1 callersMethodflattenRowData
()
row_batch.go:77
↓ 1 callersFunctionfullTableName
(schemaName, tableName string)
table_schema_cache.go:116
↓ 1 callersMethodgenerateNewServerId
()
binlog_streamer.go:467
↓ 1 callersMethodgetFingerprintDataFromSourceDb
(schemaName, tableName string, tx *sql.Tx, table *TableSchema, paginationKeys []interface{})
inline_verifier.go:527
↓ 1 callersFunctiongetRows
(db *sql.DB, schema, table, paginationKeyColumn string, columns []schema.TableColumn, paginationKeys []interfa
compression_verifier.go:233
↓ 1 callersMethodgetStmt
(query string)
utils.go:184
↓ 1 callersMethodhandleRowsEvent
(ev *replication.BinlogEvent, query []byte)
binlog_streamer.go:396
↓ 1 callersFunctionidExistsOnServer
(id uint32, db *sql.DB)
binlog_streamer.go:487
↓ 1 callersFunctionidsOnServer
(db *sql.DB)
binlog_streamer.go:502
↓ 1 callersMethodinitializeWaitUntilReplicaIsCaughtUpToMasterConnection
()
copydb/copydb.go:111
↓ 1 callersMethodinitializeWaitUntilReplicaIsCaughtUpToMasterConnection
()
sharding/sharding.go:261
↓ 1 callersMethodisIgnoreFilter
()
sharding/filter.go:275
↓ 1 callersMethodisIncludeFilter
()
sharding/filter.go:279
↓ 1 callersMethoditerateTableFingerprints
(table *TableSchema, mismatchedPaginationKeyFunc func(string, *TableSchema) error)
iterative_verifier.go:388
↓ 1 callersFunctionlinearInterpolation
(x, x0, y0, x1, y1 int)
config.go:525
↓ 1 callersFunctionlogrusWithError
(err error)
logrus_logger.go:46
↓ 1 callersFunctionlogrusWithField
--- internal factory functions (called by logger.go dispatch) ---
logrus_logger.go:38
↓ 1 callersFunctionlogrusWithFields
(fields Fields)
logrus_logger.go:42
↓ 1 callersFunctionmaxPaginationKey
(db *sql.DB, table *TableSchema)
table_schema_cache.go:422
↓ 1 callersFunctionmodifyAllRows
(ferry *testhelpers.TestFerry)
test/go/iterative_verifier_integration_test.go:287
↓ 1 callersFunctionnewLogrusDefaultLogger
()
logrus_logger.go:50
↓ 1 callersFunctionnewSpeedLogRing
(speedLogCount int)
state_tracker.go:115
↓ 1 callersMethodnewStmtFor
(p SqlPreparer, query string)
utils.go:168
↓ 1 callersFunctionnewZerologDefaultLogger
()
zerolog_logger.go:128
↓ 1 callersMethodnotifyRowCopyComplete
()
ferry.go:1107
← previousnext →401–500 of 1,224, ranked by callers