Receive: capnproto replication treat all connect errors as Unavailable

lachruzam · lachruzam · commit 189cd2e3353f · 2025-11-19T12:27:53.000+01:00
Signed-off-by: Michał Mazur &lt;mmazur.box@gmail.com&gt;
diff --git a/pkg/receive/writecapnp/client.go b/pkg/receive/writecapnp/client.go
@@ -68,7 +68,7 @@ func (r *RemoteWriteClient) RemoteWrite(ctx context.Context, in *storepb.WriteRe
 
 func (r *RemoteWriteClient) writeWithReconnect(ctx context.Context, numReconnects int, in *storepb.WriteRequest) (*storepb.WriteResponse, error) {
 	if err := r.connect(ctx); err != nil {
-		return nil, err
+		return nil, status.Errorf(codes.Unavailable, err.Error())
 	}
 
 	result, release := r.writer.Write(ctx, func(params Writer_write_Params) error {

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ func (r RemoteWriteClient) RemoteWrite(ctx context.Context, in storepb.WriteRe`
`68`	`68`
`69`	`69`	`func (r RemoteWriteClient) writeWithReconnect(ctx context.Context, numReconnects int, in storepb.WriteRequest) (*storepb.WriteResponse, error) {`
`70`	`70`	`if err := r.connect(ctx); err != nil {`
`71`		`- return nil, err`
	`71`	`+ return nil, status.Errorf(codes.Unavailable, err.Error())`
`72`	`72`	`}`
`73`	`73`
`74`	`74`	`result, release := r.writer.Write(ctx, func(params Writer_write_Params) error {`