Copilot commented on code in PR #116: URL: https://github.com/apache/dubbo-go-pixiu-samples/pull/116#discussion_r2638757044
########## grpc/reflection/proto/echo_grpc.pb.go: ########## @@ -0,0 +1,256 @@ +// +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +// Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.5.1 +// - protoc v6.32.1 +// source: echo.proto + +package proto + +import ( + context "context" + grpc "google.golang.org/grpc" + codes "google.golang.org/grpc/codes" + status "google.golang.org/grpc/status" +) + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the grpc package it is being compiled against. +// Requires gRPC-Go v1.64.0 or later. +const _ = grpc.SupportPackageIsVersion9 + +const ( + EchoService_Echo_FullMethodName = "/echo.EchoService/Echo" + EchoService_StreamEcho_FullMethodName = "/echo.EchoService/StreamEcho" + EchoService_ClientStreamEcho_FullMethodName = "/echo.EchoService/ClientStreamEcho" + EchoService_BidirectionalEcho_FullMethodName = "/echo.EchoService/BidirectionalEcho" +) + +// EchoServiceClient is the client API for EchoService 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. +// +// EchoService demonstrates gRPC Server Reflection capabilities. +// This service is designed to test dynamic message parsing through reflection. +type EchoServiceClient interface { + // Echo returns the message back with additional metadata. + Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error) + // StreamEcho demonstrates server streaming with reflection support. + StreamEcho(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EchoResponse], error) + // ClientStreamEcho demonstrates client streaming with reflection support. + ClientStreamEcho(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[EchoRequest, EchoResponse], error) + // BidirectionalEcho demonstrates bidirectional streaming. + BidirectionalEcho(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[EchoRequest, EchoResponse], error) +} + +type echoServiceClient struct { + cc grpc.ClientConnInterface +} + +func NewEchoServiceClient(cc grpc.ClientConnInterface) EchoServiceClient { + return &echoServiceClient{cc} +} + +func (c *echoServiceClient) Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(EchoResponse) + err := c.cc.Invoke(ctx, EchoService_Echo_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *echoServiceClient) StreamEcho(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EchoResponse], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &EchoService_ServiceDesc.Streams[0], EchoService_StreamEcho_FullMethodName, cOpts...) + if err != nil { + return nil, err + } + x := &grpc.GenericClientStream[EchoRequest, EchoResponse]{ClientStream: stream} + if err := x.ClientStream.SendMsg(in); err != nil { + return nil, err + } + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err + } + return x, nil +} + +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type EchoService_StreamEchoClient = grpc.ServerStreamingClient[EchoResponse] + +func (c *echoServiceClient) ClientStreamEcho(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[EchoRequest, EchoResponse], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &EchoService_ServiceDesc.Streams[1], EchoService_ClientStreamEcho_FullMethodName, cOpts...) + if err != nil { + return nil, err + } + x := &grpc.GenericClientStream[EchoRequest, EchoResponse]{ClientStream: stream} + return x, nil +} + +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type EchoService_ClientStreamEchoClient = grpc.ClientStreamingClient[EchoRequest, EchoResponse] + +func (c *echoServiceClient) BidirectionalEcho(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[EchoRequest, EchoResponse], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &EchoService_ServiceDesc.Streams[2], EchoService_BidirectionalEcho_FullMethodName, cOpts...) + if err != nil { + return nil, err + } + x := &grpc.GenericClientStream[EchoRequest, EchoResponse]{ClientStream: stream} + return x, nil +} + +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type EchoService_BidirectionalEchoClient = grpc.BidiStreamingClient[EchoRequest, EchoResponse] + +// EchoServiceServer is the server API for EchoService service. +// All implementations must embed UnimplementedEchoServiceServer +// for forward compatibility. +// +// EchoService demonstrates gRPC Server Reflection capabilities. +// This service is designed to test dynamic message parsing through reflection. +type EchoServiceServer interface { + // Echo returns the message back with additional metadata. + Echo(context.Context, *EchoRequest) (*EchoResponse, error) + // StreamEcho demonstrates server streaming with reflection support. + StreamEcho(*EchoRequest, grpc.ServerStreamingServer[EchoResponse]) error + // ClientStreamEcho demonstrates client streaming with reflection support. + ClientStreamEcho(grpc.ClientStreamingServer[EchoRequest, EchoResponse]) error + // BidirectionalEcho demonstrates bidirectional streaming. + BidirectionalEcho(grpc.BidiStreamingServer[EchoRequest, EchoResponse]) error + mustEmbedUnimplementedEchoServiceServer() +} + +// UnimplementedEchoServiceServer must be embedded to have +// forward compatible implementations. +// +// NOTE: this should be embedded by value instead of pointer to avoid a nil +// pointer dereference when methods are called. +type UnimplementedEchoServiceServer struct{} + +func (UnimplementedEchoServiceServer) Echo(context.Context, *EchoRequest) (*EchoResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Echo not implemented") +} +func (UnimplementedEchoServiceServer) StreamEcho(*EchoRequest, grpc.ServerStreamingServer[EchoResponse]) error { + return status.Errorf(codes.Unimplemented, "method StreamEcho not implemented") +} +func (UnimplementedEchoServiceServer) ClientStreamEcho(grpc.ClientStreamingServer[EchoRequest, EchoResponse]) error { + return status.Errorf(codes.Unimplemented, "method ClientStreamEcho not implemented") +} +func (UnimplementedEchoServiceServer) BidirectionalEcho(grpc.BidiStreamingServer[EchoRequest, EchoResponse]) error { + return status.Errorf(codes.Unimplemented, "method BidirectionalEcho not implemented") +} +func (UnimplementedEchoServiceServer) mustEmbedUnimplementedEchoServiceServer() {} +func (UnimplementedEchoServiceServer) testEmbeddedByValue() {} + +// UnsafeEchoServiceServer may be embedded to opt out of forward compatibility for this service. +// Use of this interface is not recommended, as added methods to EchoServiceServer will +// result in compilation errors. +type UnsafeEchoServiceServer interface { + mustEmbedUnimplementedEchoServiceServer() +} + +func RegisterEchoServiceServer(s grpc.ServiceRegistrar, srv EchoServiceServer) { + // If the following call pancis, it indicates UnimplementedEchoServiceServer was Review Comment: The comment contains a typo: "pancis" should be "panics". ```suggestion // If the following call panics, it indicates UnimplementedEchoServiceServer was ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
