.github/workflows/test.yml | 100644 | 0 | 0 | | | 1.47 KB | 7191b4135b951c062abe426ec629d68db27d7f05c8363616a8a6e4b1a19ccc6a |
.gitignore | 100644 | 0 | 0 | | | 109 Bytes | eacb17f4ec41c0b03e6b98469d761b3969b7c97a47dce7cc361a83c6eee26581 |
.rubocop.yml | 100644 | 0 | 0 | | | 3.93 KB | dc10f8918536515dc06cb8fe507cb1b5966432ddd548127e5dacbb36a5112360 |
.travis.yml | 100644 | 0 | 0 | | | 466 Bytes | c418d24aae05199d485030a1f75ebf986723beff8adb2a9ef78515b9a17f0cf8 |
Appraisals | 100644 | 0 | 0 | | | 619 Bytes | b086a30350768df979461e3c234eb7a1799193a3eb65936cfa85a5f9fd2b2d5f |
CHANGELOG.md | 100644 | 0 | 0 | | | 6.81 KB | 7184d21d0d6538830d132582538aa5d23706024d89d85c03f80f24c2c5c0751c |
Gemfile | 100644 | 0 | 0 | | | 97 Bytes | d35c702a0bba0c4fd3a64457100a6ae45827f8b8cf97eeeac2d1a8d2576bf18f |
Gemfile.lock | 100644 | 0 | 0 | | | 1.21 KB | 959e9ce8868a2d0830e240fbfa8302721509a9693ff2d2a9878e93ce8626bac9 |
LICENSE | 100644 | 0 | 0 | | | 1.5 KB | 92c7dc0233bd25453887338b81078d008822dd2fbdb113700d80722fc3fa555b |
README.md | 100644 | 0 | 0 | | | 10.3 KB | 0360fe7ff8b5b516f724c915d9bee951b165e1885eaa4f7ab67329bba493e61d |
Rakefile | 100644 | 0 | 0 | | | 698 Bytes | ea2cc726a1c4dd048df84c3217e6262c56a985178d5d22b30a16fbc5499af252 |
dev.yml | 100644 | 0 | 0 | | | 1.2 KB | c620fff0412cecfccb993760dbf9499f5ee87f2e5c209226cfc82b7cf1408a27 |
docker-compose.yml | 100644 | 0 | 0 | | | 1.34 KB | 88f1ded47efd787352e35984c6fa545ca30ba6c0479e18c29ee22b93b2c29b59 |
gemfiles/activerecord_5.2.gemfile | 100644 | 0 | 0 | | | 168 Bytes | 15e4170e78b685424849df3ce79d9ae73b8bf352cc590e0ceb7738e402f63d17 |
gemfiles/activerecord_5.2.gemfile.lock | 100644 | 0 | 0 | | | 1.16 KB | ef733ff5117c3a559b74a6817636afba5aba447709ab461faa488d9a441cb9cb |
gemfiles/activerecord_6.0.gemfile | 100644 | 0 | 0 | | | 120 Bytes | cb58df484df32a5b60351d5eee3918dd3a39cc323326ff3f06e92d13830fa581 |
gemfiles/activerecord_6.0.gemfile.lock | 100644 | 0 | 0 | | | 1.24 KB | 01569f38c6844c06910d84daa99a4dfb5930cfac4018110f37ef32bb6e8a1347 |
gemfiles/activerecord_6.1.gemfile | 100644 | 0 | 0 | | | 120 Bytes | 6c41bd770f128b0b81c4f57e563628ead80978d33d8a4a0c885728f3c07262e0 |
gemfiles/activerecord_6.1.gemfile.lock | 100644 | 0 | 0 | | | 1.21 KB | 3db4e620f6910340af4de7a834514b3ac87bbd7d5edf2be3f8dc82e21da77a1b |
gemfiles/activerecord_7.0.0.alpha2.gemfile | 100644 | 0 | 0 | | | 127 Bytes | b01ff809e19a96d462e4d886300585c1ccf895855e0d26fcdb2d5c19860c0c1d |
gemfiles/activerecord_7.0.0.alpha2.gemfile.lock | 100644 | 0 | 0 | | | 1.21 KB | 9b57f30bbab79009429e6a09d51ebe560e7ad6c4e897e47a8541ece33c4d8470 |
lhm.gemspec | 100644 | 0 | 0 | | | 1.47 KB | 37d262ef0143196e6bd32a9a351849f4213953a7d0114b05b1da54ce58365b65 |
lib/lhm-shopify.rb | 100644 | 0 | 0 | | | 14 Bytes | f7d1fa700c204dcb2292fc396ec7c21428f26d4a2906897b5d29bc38f2f2f818 |
lib/lhm.rb | 100644 | 0 | 0 | | | 5.21 KB | 2689a84d76684bf020764c4d92020fdb8b5fd1bea2250924ca99e665439c18d1 |
lib/lhm/atomic_switcher.rb | 100644 | 0 | 0 | | | 1.27 KB | b5d8475aa6ec89e7b19b086c266480514bbf6e2c65a7c38740349e9bc6d19dfd |
lib/lhm/chunk_finder.rb | 100644 | 0 | 0 | | | 819 Bytes | d9a72738c11e436245e4abec11c3923636997202eda9cb02e8a0b2f56f7805aa |
lib/lhm/chunk_insert.rb | 100644 | 0 | 0 | | | 1.52 KB | 4a44fbe554652356245b3f273d44b63d2c4b6e484bab3ea7e2cf4be8bcacbe90 |
lib/lhm/chunker.rb | 100644 | 0 | 0 | | | 3.5 KB | 2be21f971c5bb50cf43e28a57c1f2882c85a58713cda79cc561017542755ba42 |
lib/lhm/cleanup/current.rb | 100644 | 0 | 0 | | | 1.97 KB | ff1b537e5b246c466ed77d82fae3df39fd8fad51f2319df44158c3c51559fb43 |
lib/lhm/command.rb | 100644 | 0 | 0 | | | 780 Bytes | ec291c2448970264fe24722fdc73a1b82e2a7bb7538293c8615e3fd5a6a2175a |
lib/lhm/connection.rb | 100644 | 0 | 0 | | | 2.93 KB | f283b8b4057dff8049d4658f70e145cd4f62f4d70bf0a5e650ada05cd24d58e0 |
lib/lhm/entangler.rb | 100644 | 0 | 0 | | | 2.92 KB | a257b24a6f2202d1babcc1e3bae8bfb79b69f05621c6f6d60fe347e0823fd2bc |
lib/lhm/intersection.rb | 100644 | 0 | 0 | | | 979 Bytes | 49114265958cab0bff491dc53d75c9329b02d7b274752ce7481337bb987684f9 |
lib/lhm/invoker.rb | 100644 | 0 | 0 | | | 3.59 KB | b16f16a5e916eab71d407e431e346e9ebf4b5f50c6756c5e5492bc2374c03a44 |
lib/lhm/locked_switcher.rb | 100644 | 0 | 0 | | | 2.04 KB | b5764bd6a7bdeede5a2099dedb5d38ee3c4589e5320f74490c5257eee6f96c52 |
lib/lhm/migration.rb | 100644 | 0 | 0 | | | 1005 Bytes | 34bb9ce7f7cac4b32b98232f54070a02d6a91b5c6a9a02a5edc9afe321d3a362 |
lib/lhm/migrator.rb | 100644 | 0 | 0 | | | 7.37 KB | 2a7d454ca35e09d3b01b9eabb1cd827d73dcd7635399f0f20059311d1763366f |
lib/lhm/printer.rb | 100644 | 0 | 0 | | | 1.32 KB | b7a8e75f313c55d5ac73a5ec7ce3fa308ca2fece85847a15aadca408ccbef0cd |
lib/lhm/proxysql_helper.rb | 100644 | 0 | 0 | | | 157 Bytes | bde0090a62cc4a94764f7c8d941ad4894fec84e610d6bdad38b7f55b235f485b |
lib/lhm/railtie.rb | 100644 | 0 | 0 | | | 187 Bytes | a4469dc3f5186e84d3a0d092d0ac190a97c96f48580eaa59c2b5154bb28a5203 |
lib/lhm/sql_helper.rb | 100644 | 0 | 0 | | | 1.92 KB | b4e696c7d1443a1a5f792b411d57822e59c590a23d5dae3411d98d2c9d60ab88 |
lib/lhm/sql_retry.rb | 100644 | 0 | 0 | | | 7.99 KB | 62c54de8cbd36e4bc026a17f9b1a46c624395960395cd7686a738cce654b80d6 |
lib/lhm/table.rb | 100644 | 0 | 0 | | | 3.24 KB | c543fcd0e2358849f4f9e3cc998b4ca9375048bdfed34942853abf2777ea8960 |
lib/lhm/table_name.rb | 100644 | 0 | 0 | | | 393 Bytes | f628d036086beff6af0a3e737052359721f7ff95675b823162676230d53dc5fd |
lib/lhm/test_support.rb | 100644 | 0 | 0 | | | 857 Bytes | cbb082ed11b66d4159b4c9f1734ea5636672942f14678fe6c6cbe59959e42c4e |
lib/lhm/throttler.rb | 100644 | 0 | 0 | | | 933 Bytes | 5f00c944a1a42203a50ef1c2e93e55c58ee91a7f7a1a804c493407f9a9d292a6 |
lib/lhm/throttler/slave_lag.rb | 100644 | 0 | 0 | | | 4.95 KB | 1b3671be92e5ec09a66393e44c12762046068b268c3c2029f70afad11ef6bead |
lib/lhm/throttler/threads_running.rb | 100644 | 0 | 0 | | | 1.98 KB | 87161f78e8126dd4c2dd010845d3986a44cf4429d24df89a6deec71985952b7b |
lib/lhm/throttler/time.rb | 100644 | 0 | 0 | | | 583 Bytes | 1db0ab715edb39f1c2bf77d5d7707e095fdcc3584d1d68dc10351dee8b7da004 |
lib/lhm/timestamp.rb | 100644 | 0 | 0 | | | 188 Bytes | 22073aec94a57f94c51a3b79a3d5c56a81e8ea6e47508d46e112d2530ca9f13d |
lib/lhm/version.rb | 100644 | 0 | 0 | | | 131 Bytes | bdbb18aead265d0bedb7b018505295b9918e2976c16cc7b37ffce48691c1f0c8 |
scripts/helpers/wait-for-dbs.sh | 100755 | 0 | 0 | | | 619 Bytes | 5a54018aadc8784dad5c95db2682a75a5080f633e6c146e490abe3a7a20ae3be |
scripts/mysql/reader/create_replication.sql | 100644 | 0 | 0 | | | 206 Bytes | f028a0d1f74eeb718d3c6ba0e6000c5c5831ee8458b779f978ecb70bc9eeb6ae |
scripts/mysql/writer/create_test_db.sql | 100644 | 0 | 0 | | | 22 Bytes | 8b6c93058c479265005d8430f3e3d4a4c78e0900c53af2965a3ebeaf940472a5 |
scripts/mysql/writer/create_users.sql | 100644 | 0 | 0 | | | 316 Bytes | f305c6c00bf1509b53007d2ce8cddee19de30fe3eee3c85da6c9d949d065bcc6 |
scripts/proxysql/proxysql.cnf | 100644 | 0 | 0 | | | 2.25 KB | 1503867e571df6a28546698ba5a1d2b1bc06d4991f0ca10883265b0ce6d6390d |
shipit.rubygems.yml | 100644 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |
spec/.lhm.example | 100644 | 0 | 0 | | | 81 Bytes | 615b40864719c158eaa885ddb729d51eb524276b9c950b5c81c80784f3000269 |
spec/README.md | 100644 | 0 | 0 | | | 1.24 KB | 4f0ff00dbe0a724191c5ba8ae9ab0781e494b53b359a8d0dd5994443f4748dcd |
spec/fixtures/bigint_table.ddl | 100644 | 0 | 0 | | | 122 Bytes | d7fbfebda70a2664d74884e345139835818c5b3dcca2e77fa084aff275049a18 |
spec/fixtures/composite_primary_key.ddl | 100644 | 0 | 0 | | | 240 Bytes | 2b4875acbb5ca44624e87b8aeb79b686dded8901fd7bc272af21fbd75d03a5ea |
spec/fixtures/composite_primary_key_dest.ddl | 100644 | 0 | 0 | | | 245 Bytes | 61e5534d5600625149c501f9fa9a6e9c43c898becd5d530e5a5a11cd13235eff |
spec/fixtures/custom_primary_key.ddl | 100644 | 0 | 0 | | | 209 Bytes | 57a91ea8c52d88d13499d2b8a6faaedcaeb70f82e25cbaa8ee878071e6aab242 |
spec/fixtures/custom_primary_key_dest.ddl | 100644 | 0 | 0 | | | 214 Bytes | c179519fd77dabf05474ca552de6c79cc607cdc7acadce770f49b8c145a6aac5 |
spec/fixtures/destination.ddl | 100644 | 0 | 0 | | | 203 Bytes | b777f45d1b8e12007820a10e0889df1502ca13e63c37b51b70acf0a7a5a4c96f |
spec/fixtures/lines.ddl | 100644 | 0 | 0 | | | 186 Bytes | df96ac7dd6936d745b78de0d21735760c1e96ca5cb49ebe9b35139d01fe6e57b |
spec/fixtures/origin.ddl | 100644 | 0 | 0 | | | 193 Bytes | eb9164a1b3b808cf308864caad8857af0ce6ee12941f116ccff634d5a633e20c |
spec/fixtures/permissions.ddl | 100644 | 0 | 0 | | | 162 Bytes | c9bc631fa0fee5e729a72cd68467a78f5a403613cc0545adea5836c996925211 |
spec/fixtures/small_table.ddl | 100644 | 0 | 0 | | | 118 Bytes | c0ec29dc2ddc1e698a35d98ed6d59b25b86ae35a33c0dce52c308aa6a7f2e729 |
spec/fixtures/tracks.ddl | 100644 | 0 | 0 | | | 151 Bytes | bb19b0217058517b981ed2e5ea21efdaa3de6855fc6f94cbf5301c2fc238af89 |
spec/fixtures/users.ddl | 100644 | 0 | 0 | | | 527 Bytes | 43c24c6a9c08332eeb4a31f7d2539aaedaf0b4c7344e5f73c008bc6ce3510ff4 |
spec/fixtures/wo_id_int_column.ddl | 100644 | 0 | 0 | | | 147 Bytes | effcbf1d1f6af595506e7400f5e41e482a7f5c321bd084fd5cd7612a994e02e3 |
spec/integration/atomic_switcher_spec.rb | 100644 | 0 | 0 | | | 4.43 KB | 1a2d4513e17fb1ae6f78729a17672c4d918e64f4ea2789261b80045b3106f950 |
spec/integration/chunk_insert_spec.rb | 100644 | 0 | 0 | | | 916 Bytes | 64a036023e48b8ebd87f4d2dc7fc6840bc46ed45b629903d0d0eb3b15d912c38 |
spec/integration/chunker_spec.rb | 100644 | 0 | 0 | | | 9.27 KB | fe7076d5c9f4c26f7f14b6ef9928e9a874e4a226dd52a7048542ce4116dd8677 |
spec/integration/cleanup_spec.rb | 100644 | 0 | 0 | | | 5.48 KB | 9199d0e7ecca4fc9e762b50ab60931b9bb1309f8370ce07d1cca431124707000 |
spec/integration/database.yml | 100644 | 0 | 0 | | | 380 Bytes | 49611f5325f3dad0a3321c0f0cb5117b1798cf4f3721321b71303bc4120b0c8b |
spec/integration/entangler_spec.rb | 100644 | 0 | 0 | | | 1.82 KB | ac18c1a7f266474252c578a753b11ac72e04d44b366e9a783b25254d5999c678 |
spec/integration/integration_helper.rb | 100644 | 0 | 0 | | | 5.49 KB | e54b17aaf3cb6cb6ff59fc2a85e1f4f144d296d4a22ba87802c1da7095bb4516 |
spec/integration/invoker_spec.rb | 100644 | 0 | 0 | | | 978 Bytes | c0f86116dea2b3658da081d2119672f6b40b3b93f9ce6f40c6d29a33bfdd8926 |
spec/integration/lhm_spec.rb | 100644 | 0 | 0 | | | 20.1 KB | 795d63f8b5beab9c7707b8e9ef396a180e546dabe16ff22562e54e6fa1f2ac27 |
spec/integration/lock_wait_timeout_spec.rb | 100644 | 0 | 0 | | | 1.44 KB | 89c973cb94c18f384793f351d8d07a115927f632c8edbc1d2fbb2456f71a154f |
spec/integration/locked_switcher_spec.rb | 100644 | 0 | 0 | | | 1.27 KB | 59f0a793b974002a47dcae3c20ea4b2115c76b438aeabb1db5c44251f0d2f36f |
spec/integration/proxysql_spec.rb | 100644 | 0 | 0 | | | 921 Bytes | 59719abc196236b024b835731f69f09e149815f6daac0c0ec36876e647921259 |
spec/integration/sql_retry/db_connection_helper.rb | 100644 | 0 | 0 | | | 1.24 KB | d92eef583df0044f27ae2b8208994566540ae421e695f731fd2e692f830c70ce |
spec/integration/sql_retry/lock_wait_spec.rb | 100644 | 0 | 0 | | | 5.31 KB | d8da18cbc752808744e4d2c1607bc1cd0de5bed8132f7305748b72bb34f2a6bc |
spec/integration/sql_retry/lock_wait_timeout_test_helper.rb | 100644 | 0 | 0 | | | 3.92 KB | 1cd4d5269ee314f7a6472a0bb9012f4a761d2c69c6595740a7dab6e8eed9c980 |
spec/integration/sql_retry/proxysql_helper.rb | 100644 | 0 | 0 | | | 735 Bytes | 7ea91f3bb556a2408431c805dad3a14d7de1a87f502da24046610fd5d8e0ca10 |
spec/integration/sql_retry/retry_with_proxysql_spec.rb | 100644 | 0 | 0 | | | 3.95 KB | 3bacc51720ec8d6614def3f83e52506f9d081162e07d85dc95bfb90d83b1da4a |
spec/integration/table_spec.rb | 100644 | 0 | 0 | | | 2.28 KB | d97347a29a5c5dcf26c572c4ee4d88e0ef2129b33601481b24bcb60cc7c83d0c |
spec/integration/toxiproxy_helper.rb | 100644 | 0 | 0 | | | 850 Bytes | 3c90dfe9c0a051d3df7ca4e4e458317c572c381c4a2ca247d17852fcc0bcf381 |
spec/test_helper.rb | 100644 | 0 | 0 | | | 1.29 KB | 1dd9d7973e2dcfac007b586f561206817bbe8abd83dab1480d1b2617231cf8e0 |
spec/unit/atomic_switcher_spec.rb | 100644 | 0 | 0 | | | 829 Bytes | 406ae6041fed85670330d197aa8f849c333732ab6662130c9bc4017e7a9d52ec |
spec/unit/chunk_finder_spec.rb | 100644 | 0 | 0 | | | 1.95 KB | 7a50cb4b78d5a6f144340586009e0985c4c95b80a6c6a337d550f9ffd8049313 |
spec/unit/chunk_insert_spec.rb | 100644 | 0 | 0 | | | 1.51 KB | f08afa971eccb4a8f7125b23547fee6dce148fc30b8ff3a0ebc0eee64b080301 |
spec/unit/chunker_spec.rb | 100644 | 0 | 0 | | | 8.36 KB | ea09dada6c94a86608294920abe699b48223efffc8cbd7687781165502dd50f2 |
spec/unit/connection_spec.rb | 100644 | 0 | 0 | | | 2.92 KB | 8fd86c26054aaef048fa6f7503d22fa8a04957b52a85d35d1499e5f2b9c15baa |
spec/unit/entangler_spec.rb | 100644 | 0 | 0 | | | 6.15 KB | b17c34ba7a08268eab2e7593b89efb51894332f6e56afbc03097b4f87dd4cf7e |
spec/unit/intersection_spec.rb | 100644 | 0 | 0 | | | 1.5 KB | fb02f2643cbaef4f2beecffd73f6fcd4d27a4416b1bd09f81764408a97a548a7 |
spec/unit/lhm_spec.rb | 100644 | 0 | 0 | | | 878 Bytes | fc25502466bf2ed4d7167cb57e58c84d3d3c57c52a1305ae41eef29aa862b32d |
spec/unit/locked_switcher_spec.rb | 100644 | 0 | 0 | | | 1.35 KB | 1068570eb40908fb6c144c9e3b76edd23bd74dde3c34562bd02e8ee02173450c |
spec/unit/migrator_spec.rb | 100644 | 0 | 0 | | | 3.9 KB | 84b296e9b1b941a476d712712315b01f396af04ba2bc75ba1598ee8ebb0c5fcd |
spec/unit/printer_spec.rb | 100644 | 0 | 0 | | | 1.8 KB | 734ad7ef916a5d082de515ae40841b710ac600d01efdbc85478fe09b829e521a |
spec/unit/sql_helper_spec.rb | 100644 | 0 | 0 | | | 886 Bytes | 311d81ba37c842e56a637e44247453305fd8f8fc75d1cb292c92d82716547b1a |
spec/unit/table_name_spec.rb | 100644 | 0 | 0 | | | 1.56 KB | 45ccab185f95046047ac6f50eafc796317bf32192794e24ac44b57be387661e9 |
spec/unit/table_spec.rb | 100644 | 0 | 0 | | | 1.57 KB | aef588ab9285f2b3a16626fa578f7d8c1d36afcabdf7c7fc65d5a71cac71c4db |
spec/unit/throttler/slave_lag_spec.rb | 100644 | 0 | 0 | | | 9.78 KB | 7d2325cd286f4901d821d9aab0e77739d6c703c151d317c83ece1a00996420bd |
spec/unit/throttler/threads_running_spec.rb | 100644 | 0 | 0 | | | 1.85 KB | e7468328b12a2980906bd119a923046b3adac58a951e95743cad87ff97cc0d34 |
spec/unit/throttler_spec.rb | 100644 | 0 | 0 | | | 2.84 KB | db08c5e49e39aed19056d64807ebc31ef7158a3cae5ad412c9f41fa1d9673208 |
spec/unit/unit_helper.rb | 100644 | 0 | 0 | | | 562 Bytes | 730832d0af44dc31983a820fde6181bcb5b909d6f7c48b0f6cbe3bbcea29efc9 |