|
| 1 | +<<<<<<< HEAD |
| 2 | +======= |
| 3 | +load("@io_bazel_rules_go//go:def.bzl", "go_library", "go_test") |
| 4 | + |
| 5 | +go_library( |
| 6 | + name = "log_client", |
| 7 | + srcs = [ |
| 8 | + "client.go", |
| 9 | + "compacted_file_strategy.go", |
| 10 | + "import.go", |
| 11 | + "import_retry.go", |
| 12 | + "log_file_manager.go", |
| 13 | + "log_file_map.go", |
| 14 | + "log_split_strategy.go", |
| 15 | + "migration.go", |
| 16 | + "ssts.go", |
| 17 | + ], |
| 18 | + importpath = "github.com/pingcap/tidb/br/pkg/restore/log_client", |
| 19 | + visibility = ["//visibility:public"], |
| 20 | + deps = [ |
| 21 | + "//br/pkg/checkpoint", |
| 22 | + "//br/pkg/checksum", |
| 23 | + "//br/pkg/conn", |
| 24 | + "//br/pkg/conn/util", |
| 25 | + "//br/pkg/encryption", |
| 26 | + "//br/pkg/errors", |
| 27 | + "//br/pkg/glue", |
| 28 | + "//br/pkg/logutil", |
| 29 | + "//br/pkg/metautil", |
| 30 | + "//br/pkg/restore", |
| 31 | + "//br/pkg/restore/ingestrec", |
| 32 | + "//br/pkg/restore/internal/import_client", |
| 33 | + "//br/pkg/restore/internal/rawkv", |
| 34 | + "//br/pkg/restore/snap_client", |
| 35 | + "//br/pkg/restore/split", |
| 36 | + "//br/pkg/restore/tiflashrec", |
| 37 | + "//br/pkg/restore/utils", |
| 38 | + "//br/pkg/storage", |
| 39 | + "//br/pkg/stream", |
| 40 | + "//br/pkg/summary", |
| 41 | + "//br/pkg/utils", |
| 42 | + "//br/pkg/utils/iter", |
| 43 | + "//br/pkg/version", |
| 44 | + "//pkg/ddl/util", |
| 45 | + "//pkg/domain", |
| 46 | + "//pkg/kv", |
| 47 | + "//pkg/meta", |
| 48 | + "//pkg/meta/model", |
| 49 | + "//pkg/tablecodec", |
| 50 | + "//pkg/util", |
| 51 | + "//pkg/util/codec", |
| 52 | + "//pkg/util/redact", |
| 53 | + "//pkg/util/sqlexec", |
| 54 | + "//pkg/util/table-filter", |
| 55 | + "@com_github_docker_go_units//:go-units", |
| 56 | + "@com_github_fatih_color//:color", |
| 57 | + "@com_github_gogo_protobuf//proto", |
| 58 | + "@com_github_opentracing_opentracing_go//:opentracing-go", |
| 59 | + "@com_github_pingcap_errors//:errors", |
| 60 | + "@com_github_pingcap_failpoint//:failpoint", |
| 61 | + "@com_github_pingcap_kvproto//pkg/brpb", |
| 62 | + "@com_github_pingcap_kvproto//pkg/encryptionpb", |
| 63 | + "@com_github_pingcap_kvproto//pkg/errorpb", |
| 64 | + "@com_github_pingcap_kvproto//pkg/import_sstpb", |
| 65 | + "@com_github_pingcap_kvproto//pkg/kvrpcpb", |
| 66 | + "@com_github_pingcap_kvproto//pkg/metapb", |
| 67 | + "@com_github_pingcap_log//:log", |
| 68 | + "@com_github_tikv_client_go_v2//config", |
| 69 | + "@com_github_tikv_client_go_v2//kv", |
| 70 | + "@com_github_tikv_client_go_v2//util", |
| 71 | + "@com_github_tikv_pd_client//:client", |
| 72 | + "@com_github_tikv_pd_client//http", |
| 73 | + "@org_golang_google_grpc//codes", |
| 74 | + "@org_golang_google_grpc//keepalive", |
| 75 | + "@org_golang_google_grpc//status", |
| 76 | + "@org_golang_x_sync//errgroup", |
| 77 | + "@org_uber_go_multierr//:multierr", |
| 78 | + "@org_uber_go_zap//:zap", |
| 79 | + "@org_uber_go_zap//zapcore", |
| 80 | + ], |
| 81 | +) |
| 82 | + |
| 83 | +go_test( |
| 84 | + name = "log_client_test", |
| 85 | + timeout = "short", |
| 86 | + srcs = [ |
| 87 | + "client_test.go", |
| 88 | + "export_test.go", |
| 89 | + "import_retry_test.go", |
| 90 | + "import_test.go", |
| 91 | + "log_file_manager_test.go", |
| 92 | + "log_file_map_test.go", |
| 93 | + "main_test.go", |
| 94 | + "migration_test.go", |
| 95 | + ], |
| 96 | + embed = [":log_client"], |
| 97 | + flaky = True, |
| 98 | + shard_count = 50, |
| 99 | + deps = [ |
| 100 | + "//br/pkg/errors", |
| 101 | + "//br/pkg/glue", |
| 102 | + "//br/pkg/gluetidb", |
| 103 | + "//br/pkg/mock", |
| 104 | + "//br/pkg/restore", |
| 105 | + "//br/pkg/restore/internal/import_client", |
| 106 | + "//br/pkg/restore/internal/rawkv", |
| 107 | + "//br/pkg/restore/split", |
| 108 | + "//br/pkg/restore/utils", |
| 109 | + "//br/pkg/storage", |
| 110 | + "//br/pkg/stream", |
| 111 | + "//br/pkg/utils", |
| 112 | + "//br/pkg/utils/iter", |
| 113 | + "//br/pkg/utiltest", |
| 114 | + "//pkg/domain", |
| 115 | + "//pkg/kv", |
| 116 | + "//pkg/planner/core/resolve", |
| 117 | + "//pkg/session", |
| 118 | + "//pkg/sessionctx", |
| 119 | + "//pkg/store/pdtypes", |
| 120 | + "//pkg/tablecodec", |
| 121 | + "//pkg/testkit", |
| 122 | + "//pkg/testkit/testsetup", |
| 123 | + "//pkg/util/chunk", |
| 124 | + "//pkg/util/codec", |
| 125 | + "//pkg/util/sqlexec", |
| 126 | + "//pkg/util/table-filter", |
| 127 | + "@com_github_docker_go_units//:go-units", |
| 128 | + "@com_github_google_uuid//:uuid", |
| 129 | + "@com_github_pingcap_errors//:errors", |
| 130 | + "@com_github_pingcap_failpoint//:failpoint", |
| 131 | + "@com_github_pingcap_kvproto//pkg/brpb", |
| 132 | + "@com_github_pingcap_kvproto//pkg/encryptionpb", |
| 133 | + "@com_github_pingcap_kvproto//pkg/errorpb", |
| 134 | + "@com_github_pingcap_kvproto//pkg/import_sstpb", |
| 135 | + "@com_github_pingcap_kvproto//pkg/metapb", |
| 136 | + "@com_github_pingcap_log//:log", |
| 137 | + "@com_github_stretchr_testify//require", |
| 138 | + "@com_github_tikv_client_go_v2//rawkv", |
| 139 | + "@org_golang_google_grpc//codes", |
| 140 | + "@org_golang_google_grpc//keepalive", |
| 141 | + "@org_golang_google_grpc//status", |
| 142 | + "@org_uber_go_goleak//:goleak", |
| 143 | + "@org_uber_go_zap//:zap", |
| 144 | + "@org_uber_go_zap//zapcore", |
| 145 | + ], |
| 146 | +) |
| 147 | +>>>>>>> 3a378c8e384 (br: add retry for raw kv client put (#58963)) |
0 commit comments