From f6f40e03b772dcdf38c4308464e9fcc9e6d16b40 Mon Sep 17 00:00:00 2001 From: Nadav Strahilevitz Date: Wed, 13 Dec 2023 19:06:53 +0000 Subject: [PATCH] chore(api): fix typo --- api/v1beta1/datasource.pb.go | 16 ++++++++-------- api/v1beta1/datasource.proto | 2 +- api/v1beta1/datasource_grpc.pb.go | 10 +++++----- 3 files changed, 14 insertions(+), 14 deletions(-) diff --git a/api/v1beta1/datasource.pb.go b/api/v1beta1/datasource.pb.go index f89f3043d7d3..a6c2eee660bf 100644 --- a/api/v1beta1/datasource.pb.go +++ b/api/v1beta1/datasource.pb.go @@ -149,23 +149,23 @@ var file_api_v1beta1_datasource_proto_rawDesc = []byte{ 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x19, 0x0a, 0x17, 0x57, 0x72, 0x69, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0xce, 0x01, 0x0a, 0x11, 0x44, 0x61, 0x74, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0xcf, 0x01, 0x0a, 0x11, 0x44, 0x61, 0x74, 0x61, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x58, 0x0a, 0x05, 0x57, 0x72, 0x69, 0x74, 0x65, 0x12, 0x26, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x27, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x5f, 0x0a, 0x0b, 0x57, 0x72, 0x69, 0x74, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x60, 0x0a, 0x0b, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x26, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, - 0x26, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, + 0x27, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, - 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x28, 0x01, 0x42, 0x2b, 0x5a, 0x29, 0x67, 0x69, 0x74, - 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x2f, 0x61, 0x71, 0x75, 0x61, 0x73, 0x65, 0x63, 0x75, 0x72, - 0x69, 0x74, 0x79, 0x2f, 0x74, 0x72, 0x61, 0x63, 0x65, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, - 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x28, 0x01, 0x42, 0x2b, 0x5a, 0x29, 0x67, 0x69, + 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x2f, 0x61, 0x71, 0x75, 0x61, 0x73, 0x65, 0x63, 0x75, + 0x72, 0x69, 0x74, 0x79, 0x2f, 0x74, 0x72, 0x61, 0x63, 0x65, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, + 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -192,7 +192,7 @@ var file_api_v1beta1_datasource_proto_depIdxs = []int32{ 0, // 2: tracee.v1beta1.DataSourceService.Write:input_type -> tracee.v1beta1.WriteDataSourceRequest 0, // 3: tracee.v1beta1.DataSourceService.WriteStream:input_type -> tracee.v1beta1.WriteDataSourceRequest 1, // 4: tracee.v1beta1.DataSourceService.Write:output_type -> tracee.v1beta1.WriteDataSourceResponse - 0, // 5: tracee.v1beta1.DataSourceService.WriteStream:output_type -> tracee.v1beta1.WriteDataSourceRequest + 1, // 5: tracee.v1beta1.DataSourceService.WriteStream:output_type -> tracee.v1beta1.WriteDataSourceResponse 4, // [4:6] is the sub-list for method output_type 2, // [2:4] is the sub-list for method input_type 2, // [2:2] is the sub-list for extension type_name diff --git a/api/v1beta1/datasource.proto b/api/v1beta1/datasource.proto index 8a66e81296d5..7bf254933c77 100644 --- a/api/v1beta1/datasource.proto +++ b/api/v1beta1/datasource.proto @@ -16,5 +16,5 @@ message WriteDataSourceResponse{} service DataSourceService { rpc Write(WriteDataSourceRequest) returns (WriteDataSourceResponse); - rpc WriteStream(stream WriteDataSourceRequest) returns (WriteDataSourceRequest); + rpc WriteStream(stream WriteDataSourceRequest) returns (WriteDataSourceResponse); } diff --git a/api/v1beta1/datasource_grpc.pb.go b/api/v1beta1/datasource_grpc.pb.go index ea7a6e0b25f6..5d7c64d218da 100644 --- a/api/v1beta1/datasource_grpc.pb.go +++ b/api/v1beta1/datasource_grpc.pb.go @@ -54,7 +54,7 @@ func (c *dataSourceServiceClient) WriteStream(ctx context.Context, opts ...grpc. type DataSourceService_WriteStreamClient interface { Send(*WriteDataSourceRequest) error - CloseAndRecv() (*WriteDataSourceRequest, error) + CloseAndRecv() (*WriteDataSourceResponse, error) grpc.ClientStream } @@ -66,11 +66,11 @@ func (x *dataSourceServiceWriteStreamClient) Send(m *WriteDataSourceRequest) err return x.ClientStream.SendMsg(m) } -func (x *dataSourceServiceWriteStreamClient) CloseAndRecv() (*WriteDataSourceRequest, error) { +func (x *dataSourceServiceWriteStreamClient) CloseAndRecv() (*WriteDataSourceResponse, error) { if err := x.ClientStream.CloseSend(); err != nil { return nil, err } - m := new(WriteDataSourceRequest) + m := new(WriteDataSourceResponse) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } @@ -132,7 +132,7 @@ func _DataSourceService_WriteStream_Handler(srv interface{}, stream grpc.ServerS } type DataSourceService_WriteStreamServer interface { - SendAndClose(*WriteDataSourceRequest) error + SendAndClose(*WriteDataSourceResponse) error Recv() (*WriteDataSourceRequest, error) grpc.ServerStream } @@ -141,7 +141,7 @@ type dataSourceServiceWriteStreamServer struct { grpc.ServerStream } -func (x *dataSourceServiceWriteStreamServer) SendAndClose(m *WriteDataSourceRequest) error { +func (x *dataSourceServiceWriteStreamServer) SendAndClose(m *WriteDataSourceResponse) error { return x.ServerStream.SendMsg(m) }