From 8306104932782852e5860e900172f66823c11fab Mon Sep 17 00:00:00 2001 From: Roger Johansson Date: Sun, 4 Feb 2024 17:48:12 +0100 Subject: [PATCH] fix examples --- cluster/cluster.pb.go | 4 +- .../cluster_test_tool/pubsub_cluster.pb.go | 4 +- cluster/gossip.pb.go | 4 +- cluster/grain.pb.go | 4 +- cluster/pubsub.pb.go | 5 +- cluster/pubsub_test.pb.go | 4 +- examples/cluster-basic/shared/protos.pb.go | 4 +- .../cluster-broadcast/shared/protos.pb.go | 4 +- .../shared/protos_grain.pb.go | 87 +++++++------------ examples/cluster-error-response/protos.pb.go | 4 +- .../cluster-error-response/protos_grain.pb.go | 43 +++------ .../protos.pb.go | 4 +- examples/cluster-grain/shared/protos.pb.go | 4 +- .../cluster-grain/shared/protos_grain.pb.go | 19 ++-- examples/cluster-metrics/shared/protos.pb.go | 4 +- .../cluster-metrics/shared/protos_grain.pb.go | 43 +++------ .../protos.pb.go | 4 +- examples/cluster-pubsub/protos.pb.go | 4 +- examples/cluster-pubsub/protos_grain.pb.go | 2 +- examples/cluster-reentrancy/hello.pb.go | 4 +- examples/cluster-reentrancy/hello_grain.pb.go | 31 +++---- .../shared/protos.pb.go | 4 +- .../shared/protos_grain.pb.go | 43 +++------ examples/kubernetes-sample/protos.pb.go | 4 +- .../remote-activate/messages/protos.pb.go | 4 +- .../messages/protos.pb.go | 4 +- .../remote-benchmark/messages/protos.pb.go | 4 +- .../remote-channels/messages/protos.pb.go | 4 +- examples/remote-chat/messages/protos.pb.go | 4 +- examples/remote-header/messages/protos.pb.go | 4 +- .../remote-routing/messages/messages.pb.go | 4 +- examples/remote-watch/messages/protos.pb.go | 4 +- remote/remote.pb.go | 6 +- remote/remote_grpc.pb.go | 20 ++--- router/routercontracts.pb.go | 4 +- 35 files changed, 144 insertions(+), 255 deletions(-) diff --git a/cluster/cluster.pb.go b/cluster/cluster.pb.go index e0eb472a..6659f6bc 100644 --- a/cluster/cluster.pb.go +++ b/cluster/cluster.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: cluster.proto package cluster diff --git a/cluster/cluster_test_tool/pubsub_cluster.pb.go b/cluster/cluster_test_tool/pubsub_cluster.pb.go index c883d406..59e9ba11 100644 --- a/cluster/cluster_test_tool/pubsub_cluster.pb.go +++ b/cluster/cluster_test_tool/pubsub_cluster.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: pubsub_cluster.proto package cluster_test_tool diff --git a/cluster/gossip.pb.go b/cluster/gossip.pb.go index cf5e833b..2db8cb51 100644 --- a/cluster/gossip.pb.go +++ b/cluster/gossip.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: gossip.proto package cluster diff --git a/cluster/grain.pb.go b/cluster/grain.pb.go index fc3f8bf1..8836e3d9 100644 --- a/cluster/grain.pb.go +++ b/cluster/grain.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: grain.proto package cluster diff --git a/cluster/pubsub.pb.go b/cluster/pubsub.pb.go index e5ce8ed2..85529e85 100644 --- a/cluster/pubsub.pb.go +++ b/cluster/pubsub.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: pubsub.proto package cluster @@ -135,7 +135,6 @@ type SubscriberIdentity struct { unknownFields protoimpl.UnknownFields // Types that are assignable to Identity: - // // *SubscriberIdentity_Pid // *SubscriberIdentity_ClusterIdentity Identity isSubscriberIdentity_Identity `protobuf_oneof:"Identity"` diff --git a/cluster/pubsub_test.pb.go b/cluster/pubsub_test.pb.go index 250438d9..a8c473e2 100644 --- a/cluster/pubsub_test.pb.go +++ b/cluster/pubsub_test.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: pubsub_test.proto package cluster diff --git a/examples/cluster-basic/shared/protos.pb.go b/examples/cluster-basic/shared/protos.pb.go index 0022e4fd..93ea7fb8 100644 --- a/examples/cluster-basic/shared/protos.pb.go +++ b/examples/cluster-basic/shared/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package shared diff --git a/examples/cluster-broadcast/shared/protos.pb.go b/examples/cluster-broadcast/shared/protos.pb.go index 3068cd44..100b8916 100644 --- a/examples/cluster-broadcast/shared/protos.pb.go +++ b/examples/cluster-broadcast/shared/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package shared diff --git a/examples/cluster-broadcast/shared/protos_grain.pb.go b/examples/cluster-broadcast/shared/protos_grain.pb.go index d8639c33..99d75f62 100644 --- a/examples/cluster-broadcast/shared/protos_grain.pb.go +++ b/examples/cluster-broadcast/shared/protos_grain.pb.go @@ -1,12 +1,13 @@ // Code generated by protoc-gen-grain. DO NOT EDIT. // versions: -// protoc-gen-grain v0.5.1 -// protoc v4.25.0 +// protoc-gen-grain v0.4.0 +// protoc v4.24.3 // source: protos.proto package shared import ( + errors "errors" fmt "fmt" actor "github.com/asynkron/protoactor-go/actor" cluster "github.com/asynkron/protoactor-go/cluster" @@ -87,10 +88,7 @@ func (g *CalculatorGrainClient) Add(r *NumberRequest, opts ...cluster.GrainCallO case *CountResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -111,10 +109,7 @@ func (g *CalculatorGrainClient) Subtract(r *NumberRequest, opts ...cluster.Grain case *CountResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -135,10 +130,7 @@ func (g *CalculatorGrainClient) GetCurrent(r *Noop, opts ...cluster.GrainCallOpt case *CountResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -177,17 +169,14 @@ func (a *CalculatorActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] Add(NumberRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.Add(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -197,17 +186,14 @@ func (a *CalculatorActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] Subtract(NumberRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.Subtract(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -217,17 +203,14 @@ func (a *CalculatorActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] GetCurrent(Noop) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.GetCurrent(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -241,10 +224,16 @@ func (a *CalculatorActor) Receive(ctx actor.Context) { // onError should be used in ctx.ReenterAfter // you can just return error in reenterable method for other errors func (a *CalculatorActor) onError(err error) { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} a.ctx.Respond(resp) } +func respond[T proto.Message](ctx cluster.GrainContext) func(T) { + return func(resp T) { + ctx.Respond(resp) + } +} + var xTrackerFactory func() Tracker // TrackerFactory produces a Tracker @@ -317,10 +306,7 @@ func (g *TrackerGrainClient) RegisterGrain(r *RegisterMessage, opts ...cluster.G case *Noop: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -341,10 +327,7 @@ func (g *TrackerGrainClient) DeregisterGrain(r *RegisterMessage, opts ...cluster case *Noop: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -365,10 +348,7 @@ func (g *TrackerGrainClient) BroadcastGetCounts(r *Noop, opts ...cluster.GrainCa case *TotalsResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -407,17 +387,14 @@ func (a *TrackerActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] RegisterGrain(RegisterMessage) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.RegisterGrain(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -427,17 +404,14 @@ func (a *TrackerActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] DeregisterGrain(RegisterMessage) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.DeregisterGrain(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -447,17 +421,14 @@ func (a *TrackerActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] BroadcastGetCounts(Noop) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.BroadcastGetCounts(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -471,7 +442,7 @@ func (a *TrackerActor) Receive(ctx actor.Context) { // onError should be used in ctx.ReenterAfter // you can just return error in reenterable method for other errors func (a *TrackerActor) onError(err error) { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} a.ctx.Respond(resp) } diff --git a/examples/cluster-error-response/protos.pb.go b/examples/cluster-error-response/protos.pb.go index d51f7a5a..fd4fff20 100644 --- a/examples/cluster-error-response/protos.pb.go +++ b/examples/cluster-error-response/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package main diff --git a/examples/cluster-error-response/protos_grain.pb.go b/examples/cluster-error-response/protos_grain.pb.go index 42f4cee1..ba45bd1b 100644 --- a/examples/cluster-error-response/protos_grain.pb.go +++ b/examples/cluster-error-response/protos_grain.pb.go @@ -1,12 +1,13 @@ // Code generated by protoc-gen-grain. DO NOT EDIT. // versions: -// protoc-gen-grain v0.5.1 -// protoc v4.25.0 +// protoc-gen-grain v0.4.0 +// protoc v4.24.3 // source: protos.proto package main import ( + errors "errors" fmt "fmt" actor "github.com/asynkron/protoactor-go/actor" cluster "github.com/asynkron/protoactor-go/cluster" @@ -15,18 +16,6 @@ import ( time "time" ) -func ErrUserNotFound(format string, args ...interface{}) *cluster.GrainErrorResponse { - return cluster.NewGrainErrorResponse(ErrorReason_USER_NOT_FOUND.String(), fmt.Sprintf(format, args...)) -} - -func IsUserNotFound(err error) bool { - if err == nil { - return false - } - e := cluster.FromError(err) - return e.Reason == ErrorReason_USER_NOT_FOUND.String() -} - var xHelloFactory func() Hello // HelloFactory produces a Hello @@ -114,10 +103,7 @@ func (g *HelloGrainClient) Reenterable(r *ReenterableRequest, opts ...cluster.Gr case *ReenterableResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -138,10 +124,7 @@ func (g *HelloGrainClient) Hello(r *HelloRequest, opts ...cluster.GrainCallOptio case *HelloResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -180,16 +163,13 @@ func (a *HelloActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] Reenterable(ReenterableRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } err = a.inner.Reenterable(req, respond[*ReenterableResponse](a.ctx), a.onError, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -198,17 +178,14 @@ func (a *HelloActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] Hello(HelloRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.Hello(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -222,7 +199,7 @@ func (a *HelloActor) Receive(ctx actor.Context) { // onError should be used in ctx.ReenterAfter // you can just return error in reenterable method for other errors func (a *HelloActor) onError(err error) { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} a.ctx.Respond(resp) } diff --git a/examples/cluster-eventstream-broadcast/protos.pb.go b/examples/cluster-eventstream-broadcast/protos.pb.go index 3e1c829d..4139d900 100644 --- a/examples/cluster-eventstream-broadcast/protos.pb.go +++ b/examples/cluster-eventstream-broadcast/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package main diff --git a/examples/cluster-grain/shared/protos.pb.go b/examples/cluster-grain/shared/protos.pb.go index be542696..f13fa853 100644 --- a/examples/cluster-grain/shared/protos.pb.go +++ b/examples/cluster-grain/shared/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package shared diff --git a/examples/cluster-grain/shared/protos_grain.pb.go b/examples/cluster-grain/shared/protos_grain.pb.go index c6465eff..2346e686 100644 --- a/examples/cluster-grain/shared/protos_grain.pb.go +++ b/examples/cluster-grain/shared/protos_grain.pb.go @@ -1,12 +1,13 @@ // Code generated by protoc-gen-grain. DO NOT EDIT. // versions: -// protoc-gen-grain v0.5.1 -// protoc v4.25.0 +// protoc-gen-grain v0.4.0 +// protoc v4.24.3 // source: protos.proto package shared import ( + errors "errors" fmt "fmt" actor "github.com/asynkron/protoactor-go/actor" cluster "github.com/asynkron/protoactor-go/cluster" @@ -85,10 +86,7 @@ func (g *HelloGrainClient) SayHello(r *HelloRequest, opts ...cluster.GrainCallOp case *HelloResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -127,17 +125,14 @@ func (a *HelloActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] SayHello(HelloRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.SayHello(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -151,7 +146,7 @@ func (a *HelloActor) Receive(ctx actor.Context) { // onError should be used in ctx.ReenterAfter // you can just return error in reenterable method for other errors func (a *HelloActor) onError(err error) { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} a.ctx.Respond(resp) } diff --git a/examples/cluster-metrics/shared/protos.pb.go b/examples/cluster-metrics/shared/protos.pb.go index 8c7d1e64..5e8b4da8 100644 --- a/examples/cluster-metrics/shared/protos.pb.go +++ b/examples/cluster-metrics/shared/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package shared diff --git a/examples/cluster-metrics/shared/protos_grain.pb.go b/examples/cluster-metrics/shared/protos_grain.pb.go index 1f71e2eb..715927c1 100644 --- a/examples/cluster-metrics/shared/protos_grain.pb.go +++ b/examples/cluster-metrics/shared/protos_grain.pb.go @@ -1,12 +1,13 @@ // Code generated by protoc-gen-grain. DO NOT EDIT. // versions: -// protoc-gen-grain v0.5.1 -// protoc v4.25.0 +// protoc-gen-grain v0.4.0 +// protoc v4.24.3 // source: protos.proto package shared import ( + errors "errors" fmt "fmt" actor "github.com/asynkron/protoactor-go/actor" cluster "github.com/asynkron/protoactor-go/cluster" @@ -87,10 +88,7 @@ func (g *HelloGrainClient) SayHello(r *HelloRequest, opts ...cluster.GrainCallOp case *HelloResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -111,10 +109,7 @@ func (g *HelloGrainClient) Add(r *AddRequest, opts ...cluster.GrainCallOption) ( case *AddResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -135,10 +130,7 @@ func (g *HelloGrainClient) VoidFunc(r *AddRequest, opts ...cluster.GrainCallOpti case *Unit: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -177,17 +169,14 @@ func (a *HelloActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] SayHello(HelloRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.SayHello(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -197,17 +186,14 @@ func (a *HelloActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] Add(AddRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.Add(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -217,17 +203,14 @@ func (a *HelloActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] VoidFunc(AddRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.VoidFunc(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -241,7 +224,7 @@ func (a *HelloActor) Receive(ctx actor.Context) { // onError should be used in ctx.ReenterAfter // you can just return error in reenterable method for other errors func (a *HelloActor) onError(err error) { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} a.ctx.Respond(resp) } diff --git a/examples/cluster-pubsub-batching-producer/protos.pb.go b/examples/cluster-pubsub-batching-producer/protos.pb.go index 43cd2608..ff6cbc56 100644 --- a/examples/cluster-pubsub-batching-producer/protos.pb.go +++ b/examples/cluster-pubsub-batching-producer/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package main diff --git a/examples/cluster-pubsub/protos.pb.go b/examples/cluster-pubsub/protos.pb.go index 8a474441..1bf274f1 100644 --- a/examples/cluster-pubsub/protos.pb.go +++ b/examples/cluster-pubsub/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package main diff --git a/examples/cluster-pubsub/protos_grain.pb.go b/examples/cluster-pubsub/protos_grain.pb.go index f12ae3a5..6dd542a4 100644 --- a/examples/cluster-pubsub/protos_grain.pb.go +++ b/examples/cluster-pubsub/protos_grain.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-grain. DO NOT EDIT. // versions: // protoc-gen-grain v0.5.1 -// protoc v4.25.0 +// protoc v4.24.3 // source: protos.proto package main diff --git a/examples/cluster-reentrancy/hello.pb.go b/examples/cluster-reentrancy/hello.pb.go index 8ffb1f8f..df3eb88b 100644 --- a/examples/cluster-reentrancy/hello.pb.go +++ b/examples/cluster-reentrancy/hello.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: hello.proto package main diff --git a/examples/cluster-reentrancy/hello_grain.pb.go b/examples/cluster-reentrancy/hello_grain.pb.go index 4686ac4a..b84cb915 100644 --- a/examples/cluster-reentrancy/hello_grain.pb.go +++ b/examples/cluster-reentrancy/hello_grain.pb.go @@ -1,12 +1,13 @@ // Code generated by protoc-gen-grain. DO NOT EDIT. // versions: -// protoc-gen-grain v0.5.1 -// protoc v4.25.0 +// protoc-gen-grain v0.4.0 +// protoc v4.24.3 // source: hello.proto package main import ( + errors "errors" fmt "fmt" actor "github.com/asynkron/protoactor-go/actor" cluster "github.com/asynkron/protoactor-go/cluster" @@ -102,10 +103,7 @@ func (g *HelloGrainClient) InvokeService(r *InvokeServiceRequest, opts ...cluste case *InvokeServiceResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -142,10 +140,7 @@ func (g *HelloGrainClient) DoWork(r *DoWorkRequest, opts ...cluster.GrainCallOpt case *DoWorkResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -184,16 +179,13 @@ func (a *HelloActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] InvokeService(InvokeServiceRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } err = a.inner.InvokeService(req, respond[*InvokeServiceResponse](a.ctx), a.onError, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -202,17 +194,14 @@ func (a *HelloActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] DoWork(DoWorkRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.DoWork(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -226,7 +215,7 @@ func (a *HelloActor) Receive(ctx actor.Context) { // onError should be used in ctx.ReenterAfter // you can just return error in reenterable method for other errors func (a *HelloActor) onError(err error) { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} a.ctx.Respond(resp) } diff --git a/examples/cluster-restartgracefully/shared/protos.pb.go b/examples/cluster-restartgracefully/shared/protos.pb.go index 0c93c4e6..40b39b61 100644 --- a/examples/cluster-restartgracefully/shared/protos.pb.go +++ b/examples/cluster-restartgracefully/shared/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package shared diff --git a/examples/cluster-restartgracefully/shared/protos_grain.pb.go b/examples/cluster-restartgracefully/shared/protos_grain.pb.go index fa456c07..0a4f8a41 100644 --- a/examples/cluster-restartgracefully/shared/protos_grain.pb.go +++ b/examples/cluster-restartgracefully/shared/protos_grain.pb.go @@ -1,12 +1,13 @@ // Code generated by protoc-gen-grain. DO NOT EDIT. // versions: -// protoc-gen-grain v0.5.1 -// protoc v4.25.0 +// protoc-gen-grain v0.4.0 +// protoc v4.24.3 // source: protos.proto package shared import ( + errors "errors" fmt "fmt" actor "github.com/asynkron/protoactor-go/actor" cluster "github.com/asynkron/protoactor-go/cluster" @@ -87,10 +88,7 @@ func (g *CalculatorGrainClient) Add(r *NumberRequest, opts ...cluster.GrainCallO case *CountResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -111,10 +109,7 @@ func (g *CalculatorGrainClient) Subtract(r *NumberRequest, opts ...cluster.Grain case *CountResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -135,10 +130,7 @@ func (g *CalculatorGrainClient) GetCurrent(r *Void, opts ...cluster.GrainCallOpt case *CountResponse: return msg, nil case *cluster.GrainErrorResponse: - if msg == nil { - return nil, nil - } - return nil, msg + return nil, errors.New(msg.Err) default: return nil, fmt.Errorf("unknown response type %T", resp) } @@ -177,17 +169,14 @@ func (a *CalculatorActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] Add(NumberRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.Add(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -197,17 +186,14 @@ func (a *CalculatorActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] Subtract(NumberRequest) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.Subtract(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -217,17 +203,14 @@ func (a *CalculatorActor) Receive(ctx actor.Context) { err := proto.Unmarshal(msg.MessageData, req) if err != nil { ctx.Logger().Error("[Grain] GetCurrent(Void) proto.Unmarshal failed.", slog.Any("error", err)) - resp := cluster.NewGrainErrorResponse(cluster.ErrorReason_INVALID_ARGUMENT, err.Error()). - WithMetadata(map[string]string{ - "argument": req.String(), - }) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } r0, err := a.inner.GetCurrent(req, a.ctx) if err != nil { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} ctx.Respond(resp) return } @@ -241,7 +224,7 @@ func (a *CalculatorActor) Receive(ctx actor.Context) { // onError should be used in ctx.ReenterAfter // you can just return error in reenterable method for other errors func (a *CalculatorActor) onError(err error) { - resp := cluster.FromError(err) + resp := &cluster.GrainErrorResponse{Err: err.Error()} a.ctx.Respond(resp) } diff --git a/examples/kubernetes-sample/protos.pb.go b/examples/kubernetes-sample/protos.pb.go index 862314fc..b80bd8e9 100644 --- a/examples/kubernetes-sample/protos.pb.go +++ b/examples/kubernetes-sample/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package main diff --git a/examples/remote-activate/messages/protos.pb.go b/examples/remote-activate/messages/protos.pb.go index d0561b3a..78068291 100644 --- a/examples/remote-activate/messages/protos.pb.go +++ b/examples/remote-activate/messages/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package messages diff --git a/examples/remote-advertised-address/messages/protos.pb.go b/examples/remote-advertised-address/messages/protos.pb.go index bf1a3450..cafd3fdb 100644 --- a/examples/remote-advertised-address/messages/protos.pb.go +++ b/examples/remote-advertised-address/messages/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package messages diff --git a/examples/remote-benchmark/messages/protos.pb.go b/examples/remote-benchmark/messages/protos.pb.go index 099fe9a2..06948015 100644 --- a/examples/remote-benchmark/messages/protos.pb.go +++ b/examples/remote-benchmark/messages/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package messages diff --git a/examples/remote-channels/messages/protos.pb.go b/examples/remote-channels/messages/protos.pb.go index baedead5..3f4f3a80 100644 --- a/examples/remote-channels/messages/protos.pb.go +++ b/examples/remote-channels/messages/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package messages diff --git a/examples/remote-chat/messages/protos.pb.go b/examples/remote-chat/messages/protos.pb.go index ed5c162b..f0a83f6f 100644 --- a/examples/remote-chat/messages/protos.pb.go +++ b/examples/remote-chat/messages/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package messages diff --git a/examples/remote-header/messages/protos.pb.go b/examples/remote-header/messages/protos.pb.go index beb39250..d87207c3 100644 --- a/examples/remote-header/messages/protos.pb.go +++ b/examples/remote-header/messages/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package messages diff --git a/examples/remote-routing/messages/messages.pb.go b/examples/remote-routing/messages/messages.pb.go index 4f68f560..ed2e67a6 100644 --- a/examples/remote-routing/messages/messages.pb.go +++ b/examples/remote-routing/messages/messages.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: messages.proto package messages diff --git a/examples/remote-watch/messages/protos.pb.go b/examples/remote-watch/messages/protos.pb.go index 81f8b599..5a8a6de8 100644 --- a/examples/remote-watch/messages/protos.pb.go +++ b/examples/remote-watch/messages/protos.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: protos.proto package messages diff --git a/remote/remote.pb.go b/remote/remote.pb.go index 4ff9b55c..969266cb 100644 --- a/remote/remote.pb.go +++ b/remote/remote.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: remote.proto package remote @@ -76,7 +76,6 @@ type RemoteMessage struct { unknownFields protoimpl.UnknownFields // Types that are assignable to MessageType: - // // *RemoteMessage_MessageBatch // *RemoteMessage_ConnectRequest // *RemoteMessage_ConnectResponse @@ -516,7 +515,6 @@ type ConnectRequest struct { unknownFields protoimpl.UnknownFields // Types that are assignable to ConnectionType: - // // *ConnectRequest_ClientConnection // *ConnectRequest_ServerConnection ConnectionType isConnectRequest_ConnectionType `protobuf_oneof:"connection_type"` diff --git a/remote/remote_grpc.pb.go b/remote/remote_grpc.pb.go index 94a7d4c9..60772399 100644 --- a/remote/remote_grpc.pb.go +++ b/remote/remote_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.0 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v4.24.3 // source: remote.proto package remote @@ -18,12 +18,6 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 -const ( - Remoting_Receive_FullMethodName = "/remote.Remoting/Receive" - Remoting_ListProcesses_FullMethodName = "/remote.Remoting/ListProcesses" - Remoting_GetProcessDiagnostics_FullMethodName = "/remote.Remoting/GetProcessDiagnostics" -) - // RemotingClient is the client API for Remoting service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -42,7 +36,7 @@ func NewRemotingClient(cc grpc.ClientConnInterface) RemotingClient { } func (c *remotingClient) Receive(ctx context.Context, opts ...grpc.CallOption) (Remoting_ReceiveClient, error) { - stream, err := c.cc.NewStream(ctx, &Remoting_ServiceDesc.Streams[0], Remoting_Receive_FullMethodName, opts...) + stream, err := c.cc.NewStream(ctx, &Remoting_ServiceDesc.Streams[0], "/remote.Remoting/Receive", opts...) if err != nil { return nil, err } @@ -74,7 +68,7 @@ func (x *remotingReceiveClient) Recv() (*RemoteMessage, error) { func (c *remotingClient) ListProcesses(ctx context.Context, in *ListProcessesRequest, opts ...grpc.CallOption) (*ListProcessesResponse, error) { out := new(ListProcessesResponse) - err := c.cc.Invoke(ctx, Remoting_ListProcesses_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/remote.Remoting/ListProcesses", in, out, opts...) if err != nil { return nil, err } @@ -83,7 +77,7 @@ func (c *remotingClient) ListProcesses(ctx context.Context, in *ListProcessesReq func (c *remotingClient) GetProcessDiagnostics(ctx context.Context, in *GetProcessDiagnosticsRequest, opts ...grpc.CallOption) (*GetProcessDiagnosticsResponse, error) { out := new(GetProcessDiagnosticsResponse) - err := c.cc.Invoke(ctx, Remoting_GetProcessDiagnostics_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/remote.Remoting/GetProcessDiagnostics", in, out, opts...) if err != nil { return nil, err } @@ -162,7 +156,7 @@ func _Remoting_ListProcesses_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: Remoting_ListProcesses_FullMethodName, + FullMethod: "/remote.Remoting/ListProcesses", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(RemotingServer).ListProcesses(ctx, req.(*ListProcessesRequest)) @@ -180,7 +174,7 @@ func _Remoting_GetProcessDiagnostics_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: Remoting_GetProcessDiagnostics_FullMethodName, + FullMethod: "/remote.Remoting/GetProcessDiagnostics", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(RemotingServer).GetProcessDiagnostics(ctx, req.(*GetProcessDiagnosticsRequest)) diff --git a/router/routercontracts.pb.go b/router/routercontracts.pb.go index 780b7b6a..c3ce3451 100644 --- a/router/routercontracts.pb.go +++ b/router/routercontracts.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.32.0 -// protoc v4.25.0 +// protoc-gen-go v1.27.1 +// protoc v4.24.3 // source: routercontracts.proto package router