Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Shopify/ghostferry
/ functions
Functions
1,224 in github.com/Shopify/ghostferry
⨍
Functions
1,224
◇
Types & classes
176
Method
TearDownTest
()
sharding/test/callbacks_test.go:31
Method
Test0UnlimitedRetries
()
test/go/utils_test.go:52
Method
TestAddEntryIntoReverifyStoreWillDeduplicate
()
test/go/iterative_verifier_test.go:404
Method
TestAllLogMethodsNoPanic
--- All log methods execute without panic (both backends) ---
test/go/logger_test.go:197
Method
TestAllTableNames
()
test/go/table_schema_cache_test.go:261
Method
TestAllTableNamesEmpty
()
test/go/table_schema_cache_test.go:271
Method
TestAnnotations
()
test/go/dml_events_test.go:266
Method
TestAsSlice
()
test/go/table_schema_cache_test.go:286
Method
TestAsSliceEmpty
()
test/go/table_schema_cache_test.go:298
Function
TestAssertQueriesHaveEqualResultFailsIfDifferent
(t *testing.T)
testhelpers/helper_methods_test.go:19
Function
TestAssertQueriesHaveEqualResultReturnsRows
(t *testing.T)
testhelpers/helper_methods_test.go:9
Method
TestBatchSizeUpdate
()
test/go/data_iterator_test.go:240
Method
TestBeforeCutoverCompressionFailuresFailAgainDuringCutover
()
test/go/iterative_verifier_test.go:162
Method
TestBeforeCutoverDifferentCompressedSameDecompressedDataPassDuringCutover
()
test/go/iterative_verifier_test.go:175
Method
TestBeforeCutoverFailuresFailAgainDuringCutover
()
test/go/iterative_verifier_test.go:149
Method
TestBeforeCutoverFailuresPassDuringCutover
()
test/go/iterative_verifier_test.go:199
Function
TestBinaryKey_Compare
(t *testing.T)
test/go/pagination_key_test.go:136
Function
TestBinaryKey_ComparePanicsOnTypeMismatch
(t *testing.T)
test/go/pagination_key_test.go:195
Function
TestBinaryKey_IsMax
(t *testing.T)
test/go/pagination_key_test.go:275
Function
TestBinaryKey_MarshalJSON
(t *testing.T)
test/go/pagination_key_test.go:299
Function
TestBinaryKey_MarshalJSON_when_no_column
(t *testing.T)
test/go/pagination_key_test.go:313
Function
TestBinaryKey_NewBinaryKeyClones
(t *testing.T)
test/go/pagination_key_test.go:121
Function
TestBinaryKey_NumericPosition
(t *testing.T)
test/go/pagination_key_test.go:204
Function
TestBinaryKey_NumericPosition_Monotonic
(t *testing.T)
test/go/pagination_key_test.go:245
Function
TestBinaryKey_SQLValue
(t *testing.T)
test/go/pagination_key_test.go:130
Function
TestBinaryKey_String
(t *testing.T)
test/go/pagination_key_test.go:252
Method
TestBinlogDeleteEventGeneratesDeleteQuery
()
test/go/dml_events_test.go:196
Method
TestBinlogDeleteEventMetadata
()
test/go/dml_events_test.go:250
Method
TestBinlogDeleteEventWithNull
()
test/go/dml_events_test.go:218
Method
TestBinlogDeleteEventWithWrongColumnsReturnsError
()
test/go/dml_events_test.go:235
Method
TestBinlogInsertEventGeneratesInsertQuery
()
test/go/dml_events_test.go:59
Method
TestBinlogInsertEventMetadata
()
test/go/dml_events_test.go:101
Method
TestBinlogInsertEventWithWrongColumnsReturnsError
()
test/go/dml_events_test.go:86
Method
TestBinlogStreamerAddEventHandlerEventTypes
()
test/go/binlog_streamer_test.go:199
Method
TestBinlogStreamerSetsBinlogPositionOnDMLEvent
()
test/go/binlog_streamer_test.go:93
Method
TestBinlogStreamerSetsBinlogPositionOnDMLEventWithRewrites
()
test/go/binlog_streamer_test.go:122
Method
TestBinlogStreamerSetsQueryEventOnRowsEvent
()
test/go/binlog_streamer_test.go:167
Function
TestBinlogStreamerTestSuite
(t *testing.T)
test/go/binlog_streamer_test.go:213
Method
TestBinlogUpdateEventGeneratesUpdateQuery
()
test/go/dml_events_test.go:117
Method
TestBinlogUpdateEventMetadata
()
test/go/dml_events_test.go:180
Method
TestBinlogUpdateEventWithNull
()
test/go/dml_events_test.go:162
Method
TestBinlogUpdateEventWithWrongColumnsReturnsError
()
test/go/dml_events_test.go:147
Function
TestBinlogVerifySerializedStoreCopy
(t *testing.T)
test/go/inline_verifier_test.go:37
Function
TestBinlogVerifySerializedStoreRowCount
(t *testing.T)
test/go/inline_verifier_test.go:29
Function
TestBinlogWriterBufferBinlogEventsBeforeRun
TestBinlogWriterBufferBinlogEventsBeforeRun verifies that BufferBinlogEvents does not block when called before Run() has started in its own goroutine.
test/go/binlog_writer_test.go:42
Method
TestBuildTLSConfiguredAlready
()
test/go/config_test.go:140
Function
TestCallbacksTestSuite
(t *testing.T)
sharding/test/callbacks_test.go:192
Method
TestCanInitializeFerryWithValidConfig
()
test/go/replication_config_test.go:75
Method
TestChainingDoesNotMutateOriginal
--- Chaining does not mutate original (both backends) ---
test/go/logger_test.go:218
Method
TestChangingDataChangesHash
()
test/go/iterative_verifier_test.go:214
Method
TestChangingNumberValueChangesHash
()
test/go/iterative_verifier_test.go:274
Function
TestChecksumTableVerifier
(t *testing.T)
test/go/verifier_test.go:162
Function
TestCompareDecompressedDataContentDifference
(t *testing.T)
inline_verifier_test.go:22
Function
TestCompareDecompressedDataMissingSource
(t *testing.T)
inline_verifier_test.go:54
Function
TestCompareDecompressedDataMissingTarget
(t *testing.T)
inline_verifier_test.go:43
Function
TestCompareDecompressedDataNoDifference
(t *testing.T)
inline_verifier_test.go:9
Function
TestConfig
(t *testing.T)
test/go/config_test.go:204
Method
TestConfigInvalidLogBackendFallsBack
--- Config.LogBackend invalid falls back gracefully ---
test/go/logger_test.go:477
Method
TestConfigInvalidLogLevelReturnsError
--- Config.LogLevel validation ---
test/go/logger_test.go:444
Method
TestConfigValidLogLevelApplied
()
test/go/logger_test.go:453
Function
TestConfigWithBothIncludedAndIgnoredTablesIsInvalid
(t *testing.T)
sharding/test/config_test.go:11
Function
TestConfigWithInvalidIndexHintForTableIsInvalid
(t *testing.T)
sharding/test/config_test.go:42
Function
TestConfigWithInvalidIndexHintIsInvalid
(t *testing.T)
sharding/test/config_test.go:31
Function
TestConfigWithRunFerryFromReplicaWithoutValidSourceReplicationMasterIsInvalid
(t *testing.T)
sharding/test/config_test.go:21
Method
TestConnectErrorsOutIfErrorInServerIdGeneration
()
test/go/binlog_streamer_test.go:82
Method
TestConnectWithIdKeepsId
()
test/go/binlog_streamer_test.go:64
Method
TestConnectWithZeroIdGetsRandomServerId
()
test/go/binlog_streamer_test.go:73
Function
TestCopyDataWhileRenamingDatabaseAndTable
(t *testing.T)
test/go/trivial_integration_test.go:76
Function
TestCopyDataWithDeleteLoad
(t *testing.T)
test/go/trivial_integration_test.go:59
Function
TestCopyDataWithFixedPointDecimalTypes
(t *testing.T)
test/go/types_integration_test.go:104
Function
TestCopyDataWithInsertLoad
(t *testing.T)
test/go/trivial_integration_test.go:25
Function
TestCopyDataWithManyTypes
(t *testing.T)
test/go/types_integration_test.go:86
Function
TestCopyDataWithNullInColumn
(t *testing.T)
test/go/trivial_integration_test.go:139
Function
TestCopyDataWithUpdateLoad
(t *testing.T)
test/go/trivial_integration_test.go:42
Function
TestCopyDataWithoutAnyWritesToSource
(t *testing.T)
test/go/trivial_integration_test.go:14
Function
TestCopyFilterTestSuite
(t *testing.T)
sharding/test/copy_filter_test.go:338
Function
TestCopydb
(t *testing.T)
copydb/test/copydb_test.go:166
Method
TestCorruptCert
()
test/go/config_test.go:128
Method
TestCount
()
test/go/metrics_test.go:116
Method
TestCreateDatabaseAndTableWithOrdering
()
copydb/test/copydb_test.go:159
Method
TestCreateDatabaseCopiesTheRightCollation
()
copydb/test/copydb_test.go:116
Method
TestCreateDatabasesAndTablesAlreadyExists
()
copydb/test/copydb_test.go:93
Method
TestCreateDatabasesAndTablesAlreadyExistsAllowed
()
copydb/test/copydb_test.go:104
Function
TestDMLEventsTestSuite
(t *testing.T)
test/go/dml_events_test.go:393
Method
TestDataIterationBatchSizePerTableOverride
()
test/go/data_iterator_test.go:173
Method
TestDataIterationBatchSizePerTableOverrideCalculateBatchSize
()
test/go/data_iterator_test.go:245
Method
TestDataIterationBatchSizePerTableOverrideMaxRowSize
()
test/go/data_iterator_test.go:219
Method
TestDataIterationBatchSizePerTableOverrideMinRowSize
()
test/go/data_iterator_test.go:198
Function
TestDataIterator
(t *testing.T)
test/go/data_iterator_test.go:276
Function
TestDataIteratorSorterTestSuite
(t *testing.T)
test/go/data_iterator_sorter_test.go:128
Method
TestDeduplicatesHashes
()
test/go/iterative_verifier_test.go:224
Method
TestDeepChaining
()
test/go/logger_test.go:170
Method
TestDefaultBackendIsLogrus
--- SetLogBackend ---
test/go/logger_test.go:78
Method
TestDefaultMarginalia
()
test/go/config_test.go:197
Method
TestDefaultTagsWithNoMetricTags
()
test/go/metrics_test.go:33
Method
TestDefaultTagsWithOtherMetricTags
()
test/go/metrics_test.go:49
Method
TestDefaultValues
()
test/go/config_test.go:114
Method
TestDoesntReturnHashIfRecordDoesntExist
()
test/go/iterative_verifier_test.go:232
Method
TestDoneListenerGetsNotifiedWhenDone
()
test/go/data_iterator_test.go:156
Method
TestDropMetricIfSinkFull
()
test/go/metrics_test.go:161
← previous
next →
701–800 of 1,224, ranked by callers