From 6a775217cf38dca01a88c2517243efbb8cfffecd Mon Sep 17 00:00:00 2001 From: Pedro Costa <550684+pnmcosta@users.noreply.github.com> Date: Tue, 25 Feb 2025 16:29:54 +0000 Subject: [PATCH] rename flow proto messages --- management/proto/flow.pb.go | 79 +++++++++++++++---------------- management/proto/flow.proto | 6 +-- management/proto/flow_grpc.pb.go | 20 ++++---- management/proto/management.pb.go | 2 +- 4 files changed, 53 insertions(+), 54 deletions(-) diff --git a/management/proto/flow.pb.go b/management/proto/flow.pb.go index 8ae62b717..9487bd694 100644 --- a/management/proto/flow.pb.go +++ b/management/proto/flow.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.26.0 -// protoc v4.24.3 +// protoc v3.21.12 // source: flow.proto package proto @@ -20,7 +20,7 @@ const ( _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) ) -type FlowEventRequest struct { +type FlowEvent struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields @@ -31,8 +31,8 @@ type FlowEventRequest struct { FlowId string `protobuf:"bytes,2,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"` } -func (x *FlowEventRequest) Reset() { - *x = FlowEventRequest{} +func (x *FlowEvent) Reset() { + *x = FlowEvent{} if protoimpl.UnsafeEnabled { mi := &file_flow_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) @@ -40,13 +40,13 @@ func (x *FlowEventRequest) Reset() { } } -func (x *FlowEventRequest) String() string { +func (x *FlowEvent) String() string { return protoimpl.X.MessageStringOf(x) } -func (*FlowEventRequest) ProtoMessage() {} +func (*FlowEvent) ProtoMessage() {} -func (x *FlowEventRequest) ProtoReflect() protoreflect.Message { +func (x *FlowEvent) ProtoReflect() protoreflect.Message { mi := &file_flow_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) @@ -58,26 +58,26 @@ func (x *FlowEventRequest) ProtoReflect() protoreflect.Message { return mi.MessageOf(x) } -// Deprecated: Use FlowEventRequest.ProtoReflect.Descriptor instead. -func (*FlowEventRequest) Descriptor() ([]byte, []int) { +// Deprecated: Use FlowEvent.ProtoReflect.Descriptor instead. +func (*FlowEvent) Descriptor() ([]byte, []int) { return file_flow_proto_rawDescGZIP(), []int{0} } -func (x *FlowEventRequest) GetEventId() string { +func (x *FlowEvent) GetEventId() string { if x != nil { return x.EventId } return "" } -func (x *FlowEventRequest) GetFlowId() string { +func (x *FlowEvent) GetFlowId() string { if x != nil { return x.FlowId } return "" } -type FlowEventResponse struct { +type FlowEventAck struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields @@ -86,8 +86,8 @@ type FlowEventResponse struct { EventId string `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` } -func (x *FlowEventResponse) Reset() { - *x = FlowEventResponse{} +func (x *FlowEventAck) Reset() { + *x = FlowEventAck{} if protoimpl.UnsafeEnabled { mi := &file_flow_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) @@ -95,13 +95,13 @@ func (x *FlowEventResponse) Reset() { } } -func (x *FlowEventResponse) String() string { +func (x *FlowEventAck) String() string { return protoimpl.X.MessageStringOf(x) } -func (*FlowEventResponse) ProtoMessage() {} +func (*FlowEventAck) ProtoMessage() {} -func (x *FlowEventResponse) ProtoReflect() protoreflect.Message { +func (x *FlowEventAck) ProtoReflect() protoreflect.Message { mi := &file_flow_proto_msgTypes[1] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) @@ -113,12 +113,12 @@ func (x *FlowEventResponse) ProtoReflect() protoreflect.Message { return mi.MessageOf(x) } -// Deprecated: Use FlowEventResponse.ProtoReflect.Descriptor instead. -func (*FlowEventResponse) Descriptor() ([]byte, []int) { +// Deprecated: Use FlowEventAck.ProtoReflect.Descriptor instead. +func (*FlowEventAck) Descriptor() ([]byte, []int) { return file_flow_proto_rawDescGZIP(), []int{1} } -func (x *FlowEventResponse) GetEventId() string { +func (x *FlowEventAck) GetEventId() string { if x != nil { return x.EventId } @@ -129,21 +129,20 @@ var File_flow_proto protoreflect.FileDescriptor var file_flow_proto_rawDesc = []byte{ 0x0a, 0x0a, 0x66, 0x6c, 0x6f, 0x77, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0a, 0x6d, 0x61, - 0x6e, 0x61, 0x67, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x22, 0x46, 0x0a, 0x10, 0x46, 0x6c, 0x6f, 0x77, - 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x19, 0x0a, 0x08, - 0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, - 0x65, 0x76, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x17, 0x0a, 0x07, 0x66, 0x6c, 0x6f, 0x77, 0x5f, - 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x66, 0x6c, 0x6f, 0x77, 0x49, 0x64, - 0x22, 0x2e, 0x0a, 0x11, 0x46, 0x6c, 0x6f, 0x77, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x19, 0x0a, 0x08, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x69, + 0x6e, 0x61, 0x67, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x22, 0x3f, 0x0a, 0x09, 0x46, 0x6c, 0x6f, 0x77, + 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x19, 0x0a, 0x08, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x49, 0x64, - 0x32, 0x5a, 0x0a, 0x0b, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, - 0x4b, 0x0a, 0x06, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x1c, 0x2e, 0x6d, 0x61, 0x6e, 0x61, - 0x67, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x45, 0x76, 0x65, 0x6e, 0x74, - 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, - 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x65, - 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x42, 0x08, 0x5a, 0x06, - 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x12, 0x17, 0x0a, 0x07, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x06, 0x66, 0x6c, 0x6f, 0x77, 0x49, 0x64, 0x22, 0x29, 0x0a, 0x0c, 0x46, 0x6c, 0x6f, + 0x77, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x41, 0x63, 0x6b, 0x12, 0x19, 0x0a, 0x08, 0x65, 0x76, 0x65, + 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x65, 0x76, 0x65, + 0x6e, 0x74, 0x49, 0x64, 0x32, 0x4e, 0x0a, 0x0b, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x76, + 0x69, 0x63, 0x65, 0x12, 0x3f, 0x0a, 0x06, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x15, 0x2e, + 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x45, + 0x76, 0x65, 0x6e, 0x74, 0x1a, 0x18, 0x2e, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x6d, 0x65, 0x6e, + 0x74, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x41, 0x63, 0x6b, 0x22, 0x00, + 0x28, 0x01, 0x30, 0x01, 0x42, 0x08, 0x5a, 0x06, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, + 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -160,12 +159,12 @@ func file_flow_proto_rawDescGZIP() []byte { var file_flow_proto_msgTypes = make([]protoimpl.MessageInfo, 2) var file_flow_proto_goTypes = []interface{}{ - (*FlowEventRequest)(nil), // 0: management.FlowEventRequest - (*FlowEventResponse)(nil), // 1: management.FlowEventResponse + (*FlowEvent)(nil), // 0: management.FlowEvent + (*FlowEventAck)(nil), // 1: management.FlowEventAck } var file_flow_proto_depIdxs = []int32{ - 0, // 0: management.FlowService.Events:input_type -> management.FlowEventRequest - 1, // 1: management.FlowService.Events:output_type -> management.FlowEventResponse + 0, // 0: management.FlowService.Events:input_type -> management.FlowEvent + 1, // 1: management.FlowService.Events:output_type -> management.FlowEventAck 1, // [1:2] is the sub-list for method output_type 0, // [0:1] is the sub-list for method input_type 0, // [0:0] is the sub-list for extension type_name @@ -180,7 +179,7 @@ func file_flow_proto_init() { } if !protoimpl.UnsafeEnabled { file_flow_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*FlowEventRequest); i { + switch v := v.(*FlowEvent); i { case 0: return &v.state case 1: @@ -192,7 +191,7 @@ func file_flow_proto_init() { } } file_flow_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*FlowEventResponse); i { + switch v := v.(*FlowEventAck); i { case 0: return &v.state case 1: diff --git a/management/proto/flow.proto b/management/proto/flow.proto index 45489bd5b..ce909940a 100644 --- a/management/proto/flow.proto +++ b/management/proto/flow.proto @@ -6,10 +6,10 @@ package management; service FlowService { // Client to receiver streams of events and acknowledgements - rpc Events(stream FlowEventRequest) returns (stream FlowEventResponse) {} + rpc Events(stream FlowEvent) returns (stream FlowEventAck) {} } -message FlowEventRequest { +message FlowEvent { // Unique client event identifier string event_id = 1; @@ -19,7 +19,7 @@ message FlowEventRequest { // @todo define event props } -message FlowEventResponse { +message FlowEventAck { // Unique client event identifier that has been ack'ed string event_id = 1; } diff --git a/management/proto/flow_grpc.pb.go b/management/proto/flow_grpc.pb.go index 7a7ca1519..3cf4792ee 100644 --- a/management/proto/flow_grpc.pb.go +++ b/management/proto/flow_grpc.pb.go @@ -40,8 +40,8 @@ func (c *flowServiceClient) Events(ctx context.Context, opts ...grpc.CallOption) } type FlowService_EventsClient interface { - Send(*FlowEventRequest) error - Recv() (*FlowEventResponse, error) + Send(*FlowEvent) error + Recv() (*FlowEventAck, error) grpc.ClientStream } @@ -49,12 +49,12 @@ type flowServiceEventsClient struct { grpc.ClientStream } -func (x *flowServiceEventsClient) Send(m *FlowEventRequest) error { +func (x *flowServiceEventsClient) Send(m *FlowEvent) error { return x.ClientStream.SendMsg(m) } -func (x *flowServiceEventsClient) Recv() (*FlowEventResponse, error) { - m := new(FlowEventResponse) +func (x *flowServiceEventsClient) Recv() (*FlowEventAck, error) { + m := new(FlowEventAck) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } @@ -95,8 +95,8 @@ func _FlowService_Events_Handler(srv interface{}, stream grpc.ServerStream) erro } type FlowService_EventsServer interface { - Send(*FlowEventResponse) error - Recv() (*FlowEventRequest, error) + Send(*FlowEventAck) error + Recv() (*FlowEvent, error) grpc.ServerStream } @@ -104,12 +104,12 @@ type flowServiceEventsServer struct { grpc.ServerStream } -func (x *flowServiceEventsServer) Send(m *FlowEventResponse) error { +func (x *flowServiceEventsServer) Send(m *FlowEventAck) error { return x.ServerStream.SendMsg(m) } -func (x *flowServiceEventsServer) Recv() (*FlowEventRequest, error) { - m := new(FlowEventRequest) +func (x *flowServiceEventsServer) Recv() (*FlowEvent, error) { + m := new(FlowEvent) if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err } diff --git a/management/proto/management.pb.go b/management/proto/management.pb.go index df84a5a01..bbbc34e15 100644 --- a/management/proto/management.pb.go +++ b/management/proto/management.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.26.0 -// protoc v4.24.3 +// protoc v3.21.12 // source: management.proto package proto