diff options
| author | Baitinq <[email protected]> | 2024-05-25 00:33:29 +0200 |
|---|---|---|
| committer | Baitinq <[email protected]> | 2024-05-25 00:45:24 +0200 |
| commit | 5fc94dd8904ee9e5027ef97c82bb8dedc876d6ea (patch) | |
| tree | 1d4e455b52c2fd6551d53b28372c595193e9da3a /src/rest-api/handler | |
| parent | cleanup (diff) | |
| download | fs-tracer-backend-5fc94dd8904ee9e5027ef97c82bb8dedc876d6ea.tar.gz fs-tracer-backend-5fc94dd8904ee9e5027ef97c82bb8dedc876d6ea.tar.bz2 fs-tracer-backend-5fc94dd8904ee9e5027ef97c82bb8dedc876d6ea.zip | |
rest-api: deploy with bazel
Diffstat (limited to 'src/rest-api/handler')
| -rw-r--r-- | src/rest-api/handler/BUILD.bazel | 2 | ||||
| -rw-r--r-- | src/rest-api/handler/handler.go | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rest-api/handler/BUILD.bazel b/src/rest-api/handler/BUILD.bazel index 13e9a5d..89adc69 100644 --- a/src/rest-api/handler/BUILD.bazel +++ b/src/rest-api/handler/BUILD.bazel @@ -5,5 +5,5 @@ go_library( srcs = ["handler.go"], importpath = "github.com/Baitinq/fs-tracer-backend/src/rest-api/handler", visibility = ["//visibility:public"], - deps = ["//vendor/github.com/segmentio/kafka-go"], + deps = ["@com_github_segmentio_kafka_go//:kafka-go"], ) diff --git a/src/rest-api/handler/handler.go b/src/rest-api/handler/handler.go index 3fdd3f8..3454486 100644 --- a/src/rest-api/handler/handler.go +++ b/src/rest-api/handler/handler.go @@ -33,7 +33,7 @@ func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) { defer cancel() err = h.kafka_writer.WriteMessages(ctx, kafka.Message{ - Key: []byte("key-A"), //TODO: This routes to a partition. We should probably route by agent UUID + Key: []byte("key"), //TODO:This routes to a partition. We should probably route by agent UUID TODO: wont this negate having multiple topics Value: []byte(body), }) if err != nil { |