.github/workflows/test.yml | 100644 | 0 | 0 | | | 1.47 KB | ce5438f6a8960e37ef83ad5c6f41fb1a6b5a1e7673503050bb92552c3531efd8 |
.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 | | | 377 Bytes | eb5c09ffa4deca716077ed09fb2f9fcf02c47d65e71a913042d12bda4cef17c6 |
CHANGELOG.md | 100644 | 0 | 0 | | | 8.6 KB | c544ed1e28932cc685daca1799e37b1142ecd41e8271b7b57d1a0128ce1ba240 |
Gemfile | 100644 | 0 | 0 | | | 97 Bytes | d35c702a0bba0c4fd3a64457100a6ae45827f8b8cf97eeeac2d1a8d2576bf18f |
Gemfile.lock | 100644 | 0 | 0 | | | 1.24 KB | 44ca4bebef56cb121057044c13f5ecb7a3703a9023e90ee8ddad2e9409ec8774 |
LICENSE | 100644 | 0 | 0 | | | 1.5 KB | 92c7dc0233bd25453887338b81078d008822dd2fbdb113700d80722fc3fa555b |
README.md | 100644 | 0 | 0 | | | 10.9 KB | c0891b6fbc670416f7e97d00a026dae414261533d12150cc7b2f3053dbbc90a9 |
Rakefile | 100644 | 0 | 0 | | | 693 Bytes | ea79373b95967cd2da470e6ca2d29f0600a2b5584f2ee4a04e51d34600ee8d25 |
dev.yml | 100644 | 0 | 0 | | | 1.42 KB | 1cb68cbb8b52ae67f147777efb8191f80fb1f58570aa1e37b84c5ffdcc7a42ae |
docker-compose.yml | 100644 | 0 | 0 | | | 1.4 KB | 3a4ea208cfdf0add4d60df4b1beb24b980b3ae90a4403610618fa9c540cb885c |
gemfiles/activerecord_6.0.gemfile | 100644 | 0 | 0 | | | 120 Bytes | 4e859d65548fd662427c3daf5a828c142f6668cc097790881b09367b81c69a0f |
gemfiles/activerecord_6.0.gemfile.lock | 100644 | 0 | 0 | | | 1.33 KB | 397c56f0c288892e82554a4dd66d7477c9b3cf559eea1959b3e9b91fe35ac513 |
gemfiles/activerecord_6.1.gemfile | 100644 | 0 | 0 | | | 120 Bytes | 6c41bd770f128b0b81c4f57e563628ead80978d33d8a4a0c885728f3c07262e0 |
gemfiles/activerecord_6.1.gemfile.lock | 100644 | 0 | 0 | | | 1.3 KB | 0a130d0819a262e8fd9fac7437c273e89325413f2a4a579d4d3a0087478cb34a |
gemfiles/activerecord_7.0.gemfile | 100644 | 0 | 0 | | | 120 Bytes | 402b3fc1b7052bd28dbe9f9dbe1dc00dfe43b0f3715f4c603aa16e620aef807b |
gemfiles/activerecord_7.0.gemfile.lock | 100644 | 0 | 0 | | | 1.25 KB | 8e45d1f2e813f215579e7e1cf7f8c5ce6f8253e9900780cd5fe8889b60a296e3 |
gemfiles/activerecord_7.1.0.beta1.gemfile | 100644 | 0 | 0 | | | 126 Bytes | 1a118ebd1206290bec1c1ac285b8f38c8dc98a7de851f5ce7d9ffd3cc343198c |
gemfiles/activerecord_7.1.0.beta1.gemfile.lock | 100644 | 0 | 0 | | | 1.55 KB | c0b6728764120c3684c8eb96517d2b7d3ddfee1bb7b29689adf21e70805fb7fc |
lhm.gemspec | 100644 | 0 | 0 | | | 1.47 KB | c3a7099f175f657ae5043be9b422a9feeaf752b6acd36fc5ef265c369edf9cce |
lib/lhm-shopify.rb | 100644 | 0 | 0 | | | 14 Bytes | f7d1fa700c204dcb2292fc396ec7c21428f26d4a2906897b5d29bc38f2f2f818 |
lib/lhm.rb | 100644 | 0 | 0 | | | 5.15 KB | 3d6db14c7257b9f65d2af84b1412482f4acde16eeee414849323736894ea0cf1 |
lib/lhm/atomic_switcher.rb | 100644 | 0 | 0 | | | 1.23 KB | 8261589a349d25d26b7243ff07deb0d800b5602e6e2cc2ec90f1bfffc9fb34cd |
lib/lhm/chunk_finder.rb | 100644 | 0 | 0 | | | 819 Bytes | d9a72738c11e436245e4abec11c3923636997202eda9cb02e8a0b2f56f7805aa |
lib/lhm/chunk_insert.rb | 100644 | 0 | 0 | | | 1.54 KB | 3fb033e28b030896f5dbbb8759ff12256d6188466f36324b3d3a053b7d98364e |
lib/lhm/chunker.rb | 100644 | 0 | 0 | | | 3.47 KB | 3d31f1710268b38109432e84ecb43951fb18bf83d68629730537441ae42f6d7e |
lib/lhm/cleanup/current.rb | 100644 | 0 | 0 | | | 2 KB | 6b134273d98f118ed23d50087e0e550a94ae5de0528b02312fc4978173531d5c |
lib/lhm/command.rb | 100644 | 0 | 0 | | | 780 Bytes | ec291c2448970264fe24722fdc73a1b82e2a7bb7538293c8615e3fd5a6a2175a |
lib/lhm/connection.rb | 100644 | 0 | 0 | | | 3.25 KB | 819aeef661170a7b0fbf0555ed486199833ff19a78e4418bf8bd101d514b1fc2 |
lib/lhm/entangler.rb | 100644 | 0 | 0 | | | 2.87 KB | 2822f6679521b2653501ccc771d458ae30c70c0316b43f155e4e4b30789980e3 |
lib/lhm/intersection.rb | 100644 | 0 | 0 | | | 979 Bytes | 49114265958cab0bff491dc53d75c9329b02d7b274752ce7481337bb987684f9 |
lib/lhm/invoker.rb | 100644 | 0 | 0 | | | 3.65 KB | 215960c8194348911142f6a074c4a724711639764aad7e7d2137a79ec34ee282 |
lib/lhm/locked_switcher.rb | 100644 | 0 | 0 | | | 2.07 KB | 9b13c5d5323e4ec2d41821000846d1d2fa2af80e8cca7f8c9bb69808227b4431 |
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 | | | 158 Bytes | 699bf0dcae7be30431d538926ab52c5979d1b3eeedc6ecbd015d5b3ad8b43698 |
lib/lhm/railtie.rb | 100644 | 0 | 0 | | | 187 Bytes | a4469dc3f5186e84d3a0d092d0ac190a97c96f48580eaa59c2b5154bb28a5203 |
lib/lhm/sql_helper.rb | 100644 | 0 | 0 | | | 1.92 KB | e37c74ca2605410e6d93af7f0e1af67feb5c47278f685357fd1778e942082720 |
lib/lhm/sql_retry.rb | 100644 | 0 | 0 | | | 7.54 KB | c8e9125f7e26e81a321e5a2c6c4da1bc786d7f3cacfed50c10ee3a49d48e1f5e |
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 | | | 1014 Bytes | 46eeb2b204973056d257036ce1b5be2d75113788a044941fc9a1179eb64bc751 |
lib/lhm/throttler/replica_lag.rb | 100644 | 0 | 0 | | | 5.04 KB | 80dbf40b960e70b04d689c344d7ad15c424f0cf5563c9a40d4e5c5ca1efc6cd7 |
lib/lhm/throttler/slave_lag.rb | 100644 | 0 | 0 | | | 276 Bytes | ffd3981eb7451c429d2beca0466cd11851915ed7c788055ee5e30017280a0073 |
lib/lhm/throttler/threads_running.rb | 100644 | 0 | 0 | | | 2.07 KB | 68b23ee44f3d80f28c5e0ad79367fd9c7dd88205ab48dc9b35ead8336fe9f95f |
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 | 17dc0a45a6b270115dba5852f11618efb2db86c173cb304c55cc340910692399 |
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 | | | 83 Bytes | 4e1c8ea4b297aecb206ab0a4ed33b97c909cd4b1784fa3b79f5411317c0a8d3f |
spec/README.md | 100644 | 0 | 0 | | | 1.25 KB | 58f0fceb5b45a2e1988f64fb98338e0fff6c6edefdad9bc7112aab38d28b45b8 |
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.57 KB | 05746d26931540140cb899db26444b05610add35a8db5c2b61c9a647749f555e |
spec/integration/chunk_insert_spec.rb | 100644 | 0 | 0 | | | 920 Bytes | cb654c3d6f3aafd6b893b350ea6e03843e3dcb18ac65e055260379b2712e7156 |
spec/integration/chunker_spec.rb | 100644 | 0 | 0 | | | 9.55 KB | e8683d30d2907d45b6bf7187cf462a27a83c55029c0474c55d42987e51650e0c |
spec/integration/cleanup_spec.rb | 100644 | 0 | 0 | | | 5.48 KB | 9199d0e7ecca4fc9e762b50ab60931b9bb1309f8370ce07d1cca431124707000 |
spec/integration/database.yml | 100644 | 0 | 0 | | | 382 Bytes | 3379835598156811bd9e1897494b9a820f56e09b7219a5c73161ad6dcaef0dd4 |
spec/integration/entangler_spec.rb | 100644 | 0 | 0 | | | 1.83 KB | 39a5ebbaf354e9c931515cad1733bbe5d8115f22dd62cbf78273b0994d1efc5a |
spec/integration/integration_helper.rb | 100644 | 0 | 0 | | | 5.39 KB | bbf5f71ffdcd79772dd1bc6cf832de0f475c8c8191b84455e66010d4adb6dcc6 |
spec/integration/invoker_spec.rb | 100644 | 0 | 0 | | | 978 Bytes | c0f86116dea2b3658da081d2119672f6b40b3b93f9ce6f40c6d29a33bfdd8926 |
spec/integration/lhm_spec.rb | 100644 | 0 | 0 | | | 20.3 KB | 9d0fe77b690f1a4be0a9a130ed3f6b26a8244293c958b6237cbc01cea286cb3c |
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 | d558dea0c1452176fa33bf4743ca67ff08e348fe7046d806f4f85834ef3242d1 |
spec/integration/proxysql_spec.rb | 100644 | 0 | 0 | | | 937 Bytes | dc6fc7a7d54bebcaf55b909d252ab2d6b230d7d7563368ebf60d1b7033a23270 |
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.32 KB | 3ce492a628f8bd2049f6cbca060173d0907355ea3634aa5e03e1d874f11a58c8 |
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 | | | 4.05 KB | 8be663b9ae8d85482f91831c5bf1244d5405da86a9ff759c00da0f040f809776 |
spec/integration/table_spec.rb | 100644 | 0 | 0 | | | 2.28 KB | d97347a29a5c5dcf26c572c4ee4d88e0ef2129b33601481b24bcb60cc7c83d0c |
spec/integration/toxiproxy_helper.rb | 100644 | 0 | 0 | | | 850 Bytes | 9a8cc7fe760996b795c50513150e1e4d578eba4a6844eaa84f504ca8f968b4d5 |
spec/test_helper.rb | 100644 | 0 | 0 | | | 1.41 KB | 5595bbbdd5b6b2e64bdd35339e5af19945cb5e975d43a20e89c749af65527d32 |
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.88 KB | e49244f9bb2ca818b091d7d0ae695d8c2b70dd3c761fd72ee24de842f25ecad1 |
spec/unit/connection_spec.rb | 100644 | 0 | 0 | | | 3.14 KB | d6da1d3ebc2839c0a3a46daefad830dc7c1ad60f50af77de54376e86966b747c |
spec/unit/entangler_spec.rb | 100644 | 0 | 0 | | | 6.34 KB | 83d7802f35aa810b5421590fcb0eeee94ea81de6fba117451d132c888fbb9841 |
spec/unit/intersection_spec.rb | 100644 | 0 | 0 | | | 1.5 KB | fb02f2643cbaef4f2beecffd73f6fcd4d27a4416b1bd09f81764408a97a548a7 |
spec/unit/lhm_spec.rb | 100644 | 0 | 0 | | | 1.29 KB | e657d24fd07c54cc3345ad56c3cd6f92c011dfed9b03c0fe6f09b990f4e7e7f4 |
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.74 KB | 6293830c6928f9e3cf67e226b2cbd1725f8ef7f03c900e59feb328cf4535f826 |
spec/unit/sql_helper_spec.rb | 100644 | 0 | 0 | | | 909 Bytes | 053487b0e4b6bd3c29e8e0882ca3dd9140aaf485c53c89a93b644e4a930cfd82 |
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/replica_lag_spec.rb | 100644 | 0 | 0 | | | 10 KB | 7334053b7e69dbb11a4b972b632ab734ed6b5310ea18b704178fa93e03d1f1c4 |
spec/unit/throttler/threads_running_spec.rb | 100644 | 0 | 0 | | | 2.23 KB | b91801781670ba02d9bcb6401bfe0de918b0ef4eca27096974936765856a29b3 |
spec/unit/throttler_spec.rb | 100644 | 0 | 0 | | | 2.86 KB | 5c9a5ad575715cacbedf387fc87f376a70cc1a23639f9949307fb060fc8f3203 |
spec/unit/unit_helper.rb | 100644 | 0 | 0 | | | 562 Bytes | 730832d0af44dc31983a820fde6181bcb5b909d6f7c48b0f6cbe3bbcea29efc9 |