MCPcopy Create free account

hub / github.com/Shopify/ghostferry / functions

Functions1,224 in github.com/Shopify/ghostferry

⨍ Functions 1,224◇ Types & classes 176
Methodload_fixture
(filename)
test/test_helper.rb:101
Functionmain
()
test/lib/go/ddl_ghostferry/main.go:21
Functionmain
()
test/lib/go/minimal_ghostferry/main.go:7
Functionmain
()
copydb/cmd/main.go:34
Functionmain
()
sharding/cmd/main.go:31
Methodmake_ghostferry_with_pid
(pid)
test/helpers/ghostferry_helper_test.rb:30
Methodnew_ghostferry
(filepath, config: {})
test/test_helper.rb:72
Methodnew_ghostferry_with_interrupt_after_row_copy
(filepath, config: {}, after_batches_written: 0)
test/test_helper.rb:80
Methodnew_source_datawriter
(*args, **kwargs)
test/test_helper.rb:95
FunctionqueryEventHandler
(ev *replication.BinlogEvent, query []byte, es *ghostferry.BinlogEventState)
test/lib/go/ddl_ghostferry/main.go:11
Methodrandom_real_id
(connection, table)
test/helpers/data_writer_helper.rb:122
Methodreset_data
test/helpers/db_helper.rb:117
Methodrun_collation_test
(data, source_charset, target_charset, identical:)
test/integration/inline_verifier_test.rb:597
Methodseed_dynamically
(full_table_name, columns, amount_rows:)
test/integration/iterate_by_column_test.rb:80
Methodseed_random_data
(connection, database_name: DEFAULT_DB, table_name: DEFAULT_TABLE, number_of_rows: 1111)
test/helpers/db_helper.rb:123
Methodseed_random_data_in_composite_pk_table
(connection, database_name: DEFAULT_DB, table_name: DEFAULT_TABLE, number_of_rows: 1111)
test/integration/inline_verifier_test.rb:672
Methodseed_simple_database_with_single_table
test/helpers/db_helper.rb:145
Methodseed_simple_database_with_uuid_table
test/helpers/db_helper.rb:189
Methodseed_uuid_data
(connection, database_name: DEFAULT_DB, table_name: UUID_TABLE, number_of_rows: 1111)
test/helpers/db_helper.rb:171
Methodset_data_column_collation
(db, charset)
test/integration/inline_verifier_test.rb:643
Methodsetup
test/integration/interrupt_resume_test.rb:5
Methodsetup
test/integration/iterative_verifier_test.rb:4
FunctionsetupFixedPointDecimalTypeTable
(f *testhelpers.TestFerry, sourceDB, targetDB *sql.DB)
test/go/types_integration_test.go:72
FunctionsetupMultiTypeTable
(f *testhelpers.TestFerry, sourceDB, targetDB *sql.DB)
test/go/types_integration_test.go:41
FunctionsetupSingleEntryTable
(f *testhelpers.TestFerry, sourceDB, targetDB *sql.DB)
test/go/race_conditions_integration_test.go:15
FunctionsetupSingleTableDatabase
(f *testhelpers.TestFerry, sourceDB, targetDB *sql.DB)
sharding/test/trivial_integration_test.go:15
FunctionsetupSingleTableDatabaseWithExtraNullColumn
(f *testhelpers.TestFerry, sourceDB, targetDB *sql.DB)
test/go/trivial_integration_test.go:174
Methodsetup_signal_watcher
test/test_helper.rb:105
Methodsource
benchmark/ghostferry_benchmark.rb:54
Methodsource_and_target_table_metrics
Get some overall metrics like CHECKSUM, row count, sample row from tables. Generally used for test validation.
test/helpers/db_helper.rb:212
Methodsource_db
test/helpers/db_helper.rb:96
Methodsource_db_config
test/helpers/db_helper.rb:104
Methodstart_datawriter_with_ghostferry
(dw, gf, &on_write)
test/helpers/data_writer_helper.rb:9
Methodstart_ghostferry
(resuming_state = nil)
test/helpers/ghostferry_helper.rb:237
Methodstart_server
test/helpers/ghostferry_helper.rb:157
Methodstart_server_watchdog
test/helpers/ghostferry_helper.rb:325
Methodstart_synchronized_datawriter_threads
test/helpers/data_writer_helper.rb:132
Methodstop_datawriter_during_cutover
(dw, gf)
test/helpers/data_writer_helper.rb:15
Methodtable_metric
(conn, table, sample_id: nil)
test/helpers/db_helper.rb:224
Methodtarget
benchmark/ghostferry_benchmark.rb:63
Methodtarget_db
test/helpers/db_helper.rb:100
Methodtarget_db_config
test/helpers/db_helper.rb:108
Methodtarget_db_conn_with_db_selected
test/integration/inline_verifier_test.rb:664
Methodteardown
test/integration/inline_verifier_test.rb:13
Methodteardown_connections
test/helpers/db_helper.rb:90
Methodtest_ascii_data_from_utfmb3_to_utfmb4
test/integration/inline_verifier_test.rb:572
Methodtest_ascii_data_from_utfmb4_to_utfmb3
test/integration/inline_verifier_test.rb:576
Methodtest_catches_binlog_streamer_corruption
test/integration/inline_verifier_test.rb:151
Methodtest_catches_binlog_streamer_corruption_with_composite_pk
test/integration/inline_verifier_test.rb:378
Methodtest_copy_data_in_fixed_size_binary_column
test/integration/types_test.rb:316
Methodtest_copy_data_in_fixed_size_binary_column__value_completely_filled
test/integration/types_test.rb:335
Methodtest_copy_data_in_fixed_size_binary_column__value_is_empty_and_length_is_1
test/integration/types_test.rb:350
Methodtest_copy_data_with_writes_to_source
test/integration/trivial_test.rb:13
Methodtest_copy_data_without_any_writes_to_source
test/integration/trivial_test.rb:4
Methodtest_corrupted_insert_is_detected_inline_with_batch_writer
test/integration/inline_verifier_test.rb:21
Methodtest_ddl_event_handler
test/integration/ddl_events_test.rb:16
Methodtest_ddl_event_handler_with_ddl_events
test/integration/ddl_events_test.rb:25
Methodtest_decimal
test/integration/types_test.rb:363
Methodtest_default_event_handler
test/integration/ddl_events_test.rb:6
Methodtest_different_compressed_data_is_detected_inline_with_batch_writer
test/integration/inline_verifier_test.rb:49
Methodtest_different_data_in_ignored_column_passes_inline_verification
test/integration/inline_verifier_test.rb:107
Methodtest_escaped_data
test/integration/types_test.rb:254
Methodtest_interrupt_and_resume_without_last_known_schema_cache
test/integration/interrupt_resume_test.rb:34
Methodtest_interrupt_and_resume_without_last_known_schema_cache_with_uuid_table
test/integration/interrupt_resume_test.rb:723
Methodtest_interrupt_ignored_when_table_has_completed
test/integration/interrupt_resume_test.rb:76
Methodtest_interrupt_inline_verifier_will_emit_binlog_verify_store
test/integration/interrupt_resume_test.rb:170
Methodtest_interrupt_resume_between_consecutive_rows_events
originally taken from @kolbitsch-lastline in https://github.com/Shopify/ghostferry/pull/160
test/integration/interrupt_resume_test.rb:316
Methodtest_interrupt_resume_idempotence
test/integration/interrupt_resume_test.rb:404
Methodtest_interrupt_resume_idempotence_with_failure
test/integration/interrupt_resume_test.rb:484
Methodtest_interrupt_resume_idempotence_with_failure_and_writes_to_source
test/integration/interrupt_resume_test.rb:503
Methodtest_interrupt_resume_idempotence_with_multiple_interrupts
test/integration/interrupt_resume_test.rb:446
Methodtest_interrupt_resume_idempotence_with_multiple_interrupts_and_writes_to_source
test/integration/interrupt_resume_test.rb:462
Methodtest_interrupt_resume_idempotence_with_uuid_table
test/integration/interrupt_resume_test.rb:765
Methodtest_interrupt_resume_idempotence_with_writes_to_source
test/integration/interrupt_resume_test.rb:422
Methodtest_interrupt_resume_inline_verifier_will_verify_additional_rows_changed_on_source_during_interrupt
test/integration/interrupt_resume_test.rb:268
Methodtest_interrupt_resume_inline_verifier_will_verify_additional_rows_changed_on_target_during_interrupt
test/integration/interrupt_resume_test.rb:375
Methodtest_interrupt_resume_inline_verifier_will_verify_entries_in_reverify_store
test/integration/interrupt_resume_test.rb:212
Methodtest_interrupt_resume_inline_verifier_with_datawriter
test/integration/interrupt_resume_test.rb:128
Methodtest_interrupt_resume_inline_verifier_with_uuid_table
test/integration/interrupt_resume_test.rb:783
Methodtest_interrupt_resume_will_not_emit_binlog_position_for_inline_verifier_if_no_verification_is_used
test/integration/interrupt_resume_test.rb:108
Methodtest_interrupt_resume_with_writes_to_source
test/integration/interrupt_resume_test.rb:54
Methodtest_interrupt_resume_with_writes_to_source_with_uuid_table
test/integration/interrupt_resume_test.rb:745
Methodtest_interrupt_resume_without_writes_to_source_to_check_target_state_when_interrupted
test/integration/interrupt_resume_test.rb:9
Methodtest_interrupt_resume_without_writes_to_source_with_uuid_table
test/integration/interrupt_resume_test.rb:692
Methodtest_issue_149_correct
https://github.com/Shopify/ghostferry/issues/149
test/integration/interrupt_resume_test.rb:549
Methodtest_issue_149_corrupted
https://github.com/Shopify/ghostferry/issues/149
test/integration/interrupt_resume_test.rb:621
Methodtest_iterative_verifier_fails_if_binlog_streamer_incorrectly_copies_data
test/integration/iterative_verifier_test.rb:26
Methodtest_iterative_verifier_succeeds_in_normal_run
test/integration/iterative_verifier_test.rb:8
Methodtest_json_colum_not_null_with_no_default_is_invalid_this_is_fine
test/integration/types_test.rb:16
Methodtest_json_data_delete
test/integration/types_test.rb:141
Methodtest_json_data_insert
test/integration/types_test.rb:90
Methodtest_json_data_update
test/integration/types_test.rb:183
Methodtest_logged_query_omits_columns
test/integration/trivial_test.rb:26
Methodtest_null_in_different_order
test/integration/inline_verifier_test.rb:538
Methodtest_null_vs_empty_string
test/integration/inline_verifier_test.rb:485
Methodtest_null_vs_null
test/integration/inline_verifier_test.rb:467
Methodtest_null_vs_null_string
test/integration/inline_verifier_test.rb:511
Methodtest_positive_negative_zero
test/integration/inline_verifier_test.rb:420
Methodtest_progress_callback
test/integration/callbacks_test.rb:4
Methodtest_progress_callback_triggered_at_beginning_of_cutover_phase
test/integration/callbacks_test.rb:50
← previousnext →1,101–1,200 of 1,224, ranked by callers