...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package s2a_go_proto
22
23 import (
24 context "context"
25 grpc "google.golang.org/grpc"
26 codes "google.golang.org/grpc/codes"
27 status "google.golang.org/grpc/status"
28 )
29
30
31
32
33 const _ = grpc.SupportPackageIsVersion7
34
35 const (
36 S2AService_SetUpSession_FullMethodName = "/s2a.proto.S2AService/SetUpSession"
37 )
38
39
40
41
42 type S2AServiceClient interface {
43
44
45
46
47
48
49
50
51
52 SetUpSession(ctx context.Context, opts ...grpc.CallOption) (S2AService_SetUpSessionClient, error)
53 }
54
55 type s2AServiceClient struct {
56 cc grpc.ClientConnInterface
57 }
58
59 func NewS2AServiceClient(cc grpc.ClientConnInterface) S2AServiceClient {
60 return &s2AServiceClient{cc}
61 }
62
63 func (c *s2AServiceClient) SetUpSession(ctx context.Context, opts ...grpc.CallOption) (S2AService_SetUpSessionClient, error) {
64 stream, err := c.cc.NewStream(ctx, &S2AService_ServiceDesc.Streams[0], S2AService_SetUpSession_FullMethodName, opts...)
65 if err != nil {
66 return nil, err
67 }
68 x := &s2AServiceSetUpSessionClient{stream}
69 return x, nil
70 }
71
72 type S2AService_SetUpSessionClient interface {
73 Send(*SessionReq) error
74 Recv() (*SessionResp, error)
75 grpc.ClientStream
76 }
77
78 type s2AServiceSetUpSessionClient struct {
79 grpc.ClientStream
80 }
81
82 func (x *s2AServiceSetUpSessionClient) Send(m *SessionReq) error {
83 return x.ClientStream.SendMsg(m)
84 }
85
86 func (x *s2AServiceSetUpSessionClient) Recv() (*SessionResp, error) {
87 m := new(SessionResp)
88 if err := x.ClientStream.RecvMsg(m); err != nil {
89 return nil, err
90 }
91 return m, nil
92 }
93
94
95
96
97 type S2AServiceServer interface {
98
99
100
101
102
103
104
105
106
107 SetUpSession(S2AService_SetUpSessionServer) error
108 mustEmbedUnimplementedS2AServiceServer()
109 }
110
111
112 type UnimplementedS2AServiceServer struct {
113 }
114
115 func (UnimplementedS2AServiceServer) SetUpSession(S2AService_SetUpSessionServer) error {
116 return status.Errorf(codes.Unimplemented, "method SetUpSession not implemented")
117 }
118 func (UnimplementedS2AServiceServer) mustEmbedUnimplementedS2AServiceServer() {}
119
120
121
122
123 type UnsafeS2AServiceServer interface {
124 mustEmbedUnimplementedS2AServiceServer()
125 }
126
127 func RegisterS2AServiceServer(s grpc.ServiceRegistrar, srv S2AServiceServer) {
128 s.RegisterService(&S2AService_ServiceDesc, srv)
129 }
130
131 func _S2AService_SetUpSession_Handler(srv interface{}, stream grpc.ServerStream) error {
132 return srv.(S2AServiceServer).SetUpSession(&s2AServiceSetUpSessionServer{stream})
133 }
134
135 type S2AService_SetUpSessionServer interface {
136 Send(*SessionResp) error
137 Recv() (*SessionReq, error)
138 grpc.ServerStream
139 }
140
141 type s2AServiceSetUpSessionServer struct {
142 grpc.ServerStream
143 }
144
145 func (x *s2AServiceSetUpSessionServer) Send(m *SessionResp) error {
146 return x.ServerStream.SendMsg(m)
147 }
148
149 func (x *s2AServiceSetUpSessionServer) Recv() (*SessionReq, error) {
150 m := new(SessionReq)
151 if err := x.ServerStream.RecvMsg(m); err != nil {
152 return nil, err
153 }
154 return m, nil
155 }
156
157
158
159
160 var S2AService_ServiceDesc = grpc.ServiceDesc{
161 ServiceName: "s2a.proto.S2AService",
162 HandlerType: (*S2AServiceServer)(nil),
163 Methods: []grpc.MethodDesc{},
164 Streams: []grpc.StreamDesc{
165 {
166 StreamName: "SetUpSession",
167 Handler: _S2AService_SetUpSession_Handler,
168 ServerStreams: true,
169 ClientStreams: true,
170 },
171 },
172 Metadata: "internal/proto/s2a/s2a.proto",
173 }
174
View as plain text