Add support for secondary dispatching on LR2 #7344
josephschorrlint.yaml
on: pull_request
License Check
1m 26s
Lint Go
3m 15s
Lint YAML & Markdown
44s
Annotations
2 errors
|
Lint Go:
internal/dispatch/remote/cluster.go#L1
Please run go run mage.go lint:go.
diff --git a/internal/dispatch/remote/cluster.go b/internal/dispatch/remote/cluster.go
index b0d95a6..f41ad99 100644
--- a/internal/dispatch/remote/cluster.go
+++ b/internal/dispatch/remote/cluster.go
@@ -231,8 +231,10 @@ type receiver[S responseMessage] interface {
grpc.ClientStream
}
-const secondaryCursorPrefix = "$$secondary:"
-const primaryDispatcher = ""
+const (
+ secondaryCursorPrefix = "$$secondary:"
+ primaryDispatcher = ""
+)
func publishClient[Q requestMessageWithCursor, R responseMessageWithCursor](ctx context.Context, client receiver[R], stream dispatch.Stream[R], secondaryDispatchName string) error {
for {
|
|
Lint Go
Process completed with exit code 1.
|
Artifacts
Produced during runtime
| Name | Size | |
|---|---|---|
|
diff
|
449 Bytes |
|