...
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.v2.S2AService/SetUpSession"
37 )
38
39
40
41
42 type S2AServiceClient interface {
43
44
45 SetUpSession(ctx context.Context, opts ...grpc.CallOption) (S2AService_SetUpSessionClient, error)
46 }
47
48 type s2AServiceClient struct {
49 cc grpc.ClientConnInterface
50 }
51
52 func NewS2AServiceClient(cc grpc.ClientConnInterface) S2AServiceClient {
53 return &s2AServiceClient{cc}
54 }
55
56 func (c *s2AServiceClient) SetUpSession(ctx context.Context, opts ...grpc.CallOption) (S2AService_SetUpSessionClient, error) {
57 stream, err := c.cc.NewStream(ctx, &S2AService_ServiceDesc.Streams[0], S2AService_SetUpSession_FullMethodName, opts...)
58 if err != nil {
59 return nil, err
60 }
61 x := &s2AServiceSetUpSessionClient{stream}
62 return x, nil
63 }
64
65 type S2AService_SetUpSessionClient interface {
66 Send(*SessionReq) error
67 Recv() (*SessionResp, error)
68 grpc.ClientStream
69 }
70
71 type s2AServiceSetUpSessionClient struct {
72 grpc.ClientStream
73 }
74
75 func (x *s2AServiceSetUpSessionClient) Send(m *SessionReq) error {
76 return x.ClientStream.SendMsg(m)
77 }
78
79 func (x *s2AServiceSetUpSessionClient) Recv() (*SessionResp, error) {
80 m := new(SessionResp)
81 if err := x.ClientStream.RecvMsg(m); err != nil {
82 return nil, err
83 }
84 return m, nil
85 }
86
87
88
89
90 type S2AServiceServer interface {
91
92
93 SetUpSession(S2AService_SetUpSessionServer) error
94 mustEmbedUnimplementedS2AServiceServer()
95 }
96
97
98 type UnimplementedS2AServiceServer struct {
99 }
100
101 func (UnimplementedS2AServiceServer) SetUpSession(S2AService_SetUpSessionServer) error {
102 return status.Errorf(codes.Unimplemented, "method SetUpSession not implemented")
103 }
104 func (UnimplementedS2AServiceServer) mustEmbedUnimplementedS2AServiceServer() {}
105
106
107
108
109 type UnsafeS2AServiceServer interface {
110 mustEmbedUnimplementedS2AServiceServer()
111 }
112
113 func RegisterS2AServiceServer(s grpc.ServiceRegistrar, srv S2AServiceServer) {
114 s.RegisterService(&S2AService_ServiceDesc, srv)
115 }
116
117 func _S2AService_SetUpSession_Handler(srv interface{}, stream grpc.ServerStream) error {
118 return srv.(S2AServiceServer).SetUpSession(&s2AServiceSetUpSessionServer{stream})
119 }
120
121 type S2AService_SetUpSessionServer interface {
122 Send(*SessionResp) error
123 Recv() (*SessionReq, error)
124 grpc.ServerStream
125 }
126
127 type s2AServiceSetUpSessionServer struct {
128 grpc.ServerStream
129 }
130
131 func (x *s2AServiceSetUpSessionServer) Send(m *SessionResp) error {
132 return x.ServerStream.SendMsg(m)
133 }
134
135 func (x *s2AServiceSetUpSessionServer) Recv() (*SessionReq, error) {
136 m := new(SessionReq)
137 if err := x.ServerStream.RecvMsg(m); err != nil {
138 return nil, err
139 }
140 return m, nil
141 }
142
143
144
145
146 var S2AService_ServiceDesc = grpc.ServiceDesc{
147 ServiceName: "s2a.proto.v2.S2AService",
148 HandlerType: (*S2AServiceServer)(nil),
149 Methods: []grpc.MethodDesc{},
150 Streams: []grpc.StreamDesc{
151 {
152 StreamName: "SetUpSession",
153 Handler: _S2AService_SetUpSession_Handler,
154 ServerStreams: true,
155 ClientStreams: true,
156 },
157 },
158 Metadata: "internal/proto/v2/s2a/s2a.proto",
159 }
160
View as plain text