...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24 package grpc_gcp
25
26 import (
27 context "context"
28 grpc "google.golang.org/grpc"
29 codes "google.golang.org/grpc/codes"
30 status "google.golang.org/grpc/status"
31 )
32
33
34
35
36 const _ = grpc.SupportPackageIsVersion9
37
38 const (
39 HandshakerService_DoHandshake_FullMethodName = "/grpc.gcp.HandshakerService/DoHandshake"
40 )
41
42
43
44
45 type HandshakerServiceClient interface {
46
47
48
49
50
51
52 DoHandshake(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[HandshakerReq, HandshakerResp], error)
53 }
54
55 type handshakerServiceClient struct {
56 cc grpc.ClientConnInterface
57 }
58
59 func NewHandshakerServiceClient(cc grpc.ClientConnInterface) HandshakerServiceClient {
60 return &handshakerServiceClient{cc}
61 }
62
63 func (c *handshakerServiceClient) DoHandshake(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[HandshakerReq, HandshakerResp], error) {
64 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
65 stream, err := c.cc.NewStream(ctx, &HandshakerService_ServiceDesc.Streams[0], HandshakerService_DoHandshake_FullMethodName, cOpts...)
66 if err != nil {
67 return nil, err
68 }
69 x := &grpc.GenericClientStream[HandshakerReq, HandshakerResp]{ClientStream: stream}
70 return x, nil
71 }
72
73
74 type HandshakerService_DoHandshakeClient = grpc.BidiStreamingClient[HandshakerReq, HandshakerResp]
75
76
77
78
79 type HandshakerServiceServer interface {
80
81
82
83
84
85
86 DoHandshake(grpc.BidiStreamingServer[HandshakerReq, HandshakerResp]) error
87 mustEmbedUnimplementedHandshakerServiceServer()
88 }
89
90
91 type UnimplementedHandshakerServiceServer struct {
92 }
93
94 func (UnimplementedHandshakerServiceServer) DoHandshake(grpc.BidiStreamingServer[HandshakerReq, HandshakerResp]) error {
95 return status.Errorf(codes.Unimplemented, "method DoHandshake not implemented")
96 }
97 func (UnimplementedHandshakerServiceServer) mustEmbedUnimplementedHandshakerServiceServer() {}
98
99
100
101
102 type UnsafeHandshakerServiceServer interface {
103 mustEmbedUnimplementedHandshakerServiceServer()
104 }
105
106 func RegisterHandshakerServiceServer(s grpc.ServiceRegistrar, srv HandshakerServiceServer) {
107 s.RegisterService(&HandshakerService_ServiceDesc, srv)
108 }
109
110 func _HandshakerService_DoHandshake_Handler(srv interface{}, stream grpc.ServerStream) error {
111 return srv.(HandshakerServiceServer).DoHandshake(&grpc.GenericServerStream[HandshakerReq, HandshakerResp]{ServerStream: stream})
112 }
113
114
115 type HandshakerService_DoHandshakeServer = grpc.BidiStreamingServer[HandshakerReq, HandshakerResp]
116
117
118
119
120 var HandshakerService_ServiceDesc = grpc.ServiceDesc{
121 ServiceName: "grpc.gcp.HandshakerService",
122 HandlerType: (*HandshakerServiceServer)(nil),
123 Methods: []grpc.MethodDesc{},
124 Streams: []grpc.StreamDesc{
125 {
126 StreamName: "DoHandshake",
127 Handler: _HandshakerService_DoHandshake_Handler,
128 ServerStreams: true,
129 ClientStreams: true,
130 },
131 },
132 Metadata: "grpc/gcp/handshaker.proto",
133 }
134
View as plain text