add json tags

flowerinthenight · Jun 23, 2024 · 461e0cc · 461e0cc
1 parent 47af2b6
commit 461e0cc
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/hedge.go b/hedge.go
@@ -158,8 +158,8 @@ func (w withGrpcHostPort) Apply(op *Op) { op.grpcHostPort = string(w) }
 func WithGrpcHostPort(v string) Option { return withGrpcHostPort(v) }
 
 type StreamMessage struct {
-	Payload *protov1.Payload
-	Error   error
+	Payload *protov1.Payload `json:"payload"`
+	Error   error            `json:"error"`
 }
 
 type withLeaderStreamChannels struct {
@@ -737,8 +737,8 @@ func (op *Op) Send(ctx context.Context, msg []byte) ([]byte, error) {
 }
 
 type StreamToLeaderOutput struct {
-	In  chan *StreamMessage
-	Out chan *StreamMessage
+	In  chan *StreamMessage `json:"in"`
+	Out chan *StreamMessage `json:"out"`
 }
 
 // StreamToLeader returns an input and output channels for streaming to leader. To use the channels,