1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "git.fd.io/govpp.git/api"
11 vpe "git.fd.io/govpp.git/binapi/vpe"
14 // RPCService defines RPC service ipsec.
15 type RPCService interface {
16 IpsecBackendDump(ctx context.Context, in *IpsecBackendDump) (RPCService_IpsecBackendDumpClient, error)
17 IpsecInterfaceAddDelSpd(ctx context.Context, in *IpsecInterfaceAddDelSpd) (*IpsecInterfaceAddDelSpdReply, error)
18 IpsecItfCreate(ctx context.Context, in *IpsecItfCreate) (*IpsecItfCreateReply, error)
19 IpsecItfDelete(ctx context.Context, in *IpsecItfDelete) (*IpsecItfDeleteReply, error)
20 IpsecItfDump(ctx context.Context, in *IpsecItfDump) (RPCService_IpsecItfDumpClient, error)
21 IpsecSaDump(ctx context.Context, in *IpsecSaDump) (RPCService_IpsecSaDumpClient, error)
22 IpsecSaV2Dump(ctx context.Context, in *IpsecSaV2Dump) (RPCService_IpsecSaV2DumpClient, error)
23 IpsecSaV3Dump(ctx context.Context, in *IpsecSaV3Dump) (RPCService_IpsecSaV3DumpClient, error)
24 IpsecSadEntryAddDel(ctx context.Context, in *IpsecSadEntryAddDel) (*IpsecSadEntryAddDelReply, error)
25 IpsecSadEntryAddDelV2(ctx context.Context, in *IpsecSadEntryAddDelV2) (*IpsecSadEntryAddDelV2Reply, error)
26 IpsecSadEntryAddDelV3(ctx context.Context, in *IpsecSadEntryAddDelV3) (*IpsecSadEntryAddDelV3Reply, error)
27 IpsecSelectBackend(ctx context.Context, in *IpsecSelectBackend) (*IpsecSelectBackendReply, error)
28 IpsecSetAsyncMode(ctx context.Context, in *IpsecSetAsyncMode) (*IpsecSetAsyncModeReply, error)
29 IpsecSpdAddDel(ctx context.Context, in *IpsecSpdAddDel) (*IpsecSpdAddDelReply, error)
30 IpsecSpdDump(ctx context.Context, in *IpsecSpdDump) (RPCService_IpsecSpdDumpClient, error)
31 IpsecSpdEntryAddDel(ctx context.Context, in *IpsecSpdEntryAddDel) (*IpsecSpdEntryAddDelReply, error)
32 IpsecSpdInterfaceDump(ctx context.Context, in *IpsecSpdInterfaceDump) (RPCService_IpsecSpdInterfaceDumpClient, error)
33 IpsecSpdsDump(ctx context.Context, in *IpsecSpdsDump) (RPCService_IpsecSpdsDumpClient, error)
34 IpsecTunnelProtectDel(ctx context.Context, in *IpsecTunnelProtectDel) (*IpsecTunnelProtectDelReply, error)
35 IpsecTunnelProtectDump(ctx context.Context, in *IpsecTunnelProtectDump) (RPCService_IpsecTunnelProtectDumpClient, error)
36 IpsecTunnelProtectUpdate(ctx context.Context, in *IpsecTunnelProtectUpdate) (*IpsecTunnelProtectUpdateReply, error)
39 type serviceClient struct {
43 func NewServiceClient(conn api.Connection) RPCService {
44 return &serviceClient{conn}
47 func (c *serviceClient) IpsecBackendDump(ctx context.Context, in *IpsecBackendDump) (RPCService_IpsecBackendDumpClient, error) {
48 stream, err := c.conn.NewStream(ctx)
52 x := &serviceClient_IpsecBackendDumpClient{stream}
53 if err := x.Stream.SendMsg(in); err != nil {
56 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
62 type RPCService_IpsecBackendDumpClient interface {
63 Recv() (*IpsecBackendDetails, error)
67 type serviceClient_IpsecBackendDumpClient struct {
71 func (c *serviceClient_IpsecBackendDumpClient) Recv() (*IpsecBackendDetails, error) {
72 msg, err := c.Stream.RecvMsg()
76 switch m := msg.(type) {
77 case *IpsecBackendDetails:
79 case *vpe.ControlPingReply:
80 err = c.Stream.Close()
86 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
90 func (c *serviceClient) IpsecInterfaceAddDelSpd(ctx context.Context, in *IpsecInterfaceAddDelSpd) (*IpsecInterfaceAddDelSpdReply, error) {
91 out := new(IpsecInterfaceAddDelSpdReply)
92 err := c.conn.Invoke(ctx, in, out)
96 return out, api.RetvalToVPPApiError(out.Retval)
99 func (c *serviceClient) IpsecItfCreate(ctx context.Context, in *IpsecItfCreate) (*IpsecItfCreateReply, error) {
100 out := new(IpsecItfCreateReply)
101 err := c.conn.Invoke(ctx, in, out)
105 return out, api.RetvalToVPPApiError(out.Retval)
108 func (c *serviceClient) IpsecItfDelete(ctx context.Context, in *IpsecItfDelete) (*IpsecItfDeleteReply, error) {
109 out := new(IpsecItfDeleteReply)
110 err := c.conn.Invoke(ctx, in, out)
114 return out, api.RetvalToVPPApiError(out.Retval)
117 func (c *serviceClient) IpsecItfDump(ctx context.Context, in *IpsecItfDump) (RPCService_IpsecItfDumpClient, error) {
118 stream, err := c.conn.NewStream(ctx)
122 x := &serviceClient_IpsecItfDumpClient{stream}
123 if err := x.Stream.SendMsg(in); err != nil {
126 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
132 type RPCService_IpsecItfDumpClient interface {
133 Recv() (*IpsecItfDetails, error)
137 type serviceClient_IpsecItfDumpClient struct {
141 func (c *serviceClient_IpsecItfDumpClient) Recv() (*IpsecItfDetails, error) {
142 msg, err := c.Stream.RecvMsg()
146 switch m := msg.(type) {
147 case *IpsecItfDetails:
149 case *vpe.ControlPingReply:
150 err = c.Stream.Close()
156 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
160 func (c *serviceClient) IpsecSaDump(ctx context.Context, in *IpsecSaDump) (RPCService_IpsecSaDumpClient, error) {
161 stream, err := c.conn.NewStream(ctx)
165 x := &serviceClient_IpsecSaDumpClient{stream}
166 if err := x.Stream.SendMsg(in); err != nil {
169 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
175 type RPCService_IpsecSaDumpClient interface {
176 Recv() (*IpsecSaDetails, error)
180 type serviceClient_IpsecSaDumpClient struct {
184 func (c *serviceClient_IpsecSaDumpClient) Recv() (*IpsecSaDetails, error) {
185 msg, err := c.Stream.RecvMsg()
189 switch m := msg.(type) {
190 case *IpsecSaDetails:
192 case *vpe.ControlPingReply:
193 err = c.Stream.Close()
199 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
203 func (c *serviceClient) IpsecSaV2Dump(ctx context.Context, in *IpsecSaV2Dump) (RPCService_IpsecSaV2DumpClient, error) {
204 stream, err := c.conn.NewStream(ctx)
208 x := &serviceClient_IpsecSaV2DumpClient{stream}
209 if err := x.Stream.SendMsg(in); err != nil {
212 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
218 type RPCService_IpsecSaV2DumpClient interface {
219 Recv() (*IpsecSaV2Details, error)
223 type serviceClient_IpsecSaV2DumpClient struct {
227 func (c *serviceClient_IpsecSaV2DumpClient) Recv() (*IpsecSaV2Details, error) {
228 msg, err := c.Stream.RecvMsg()
232 switch m := msg.(type) {
233 case *IpsecSaV2Details:
235 case *vpe.ControlPingReply:
236 err = c.Stream.Close()
242 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
246 func (c *serviceClient) IpsecSaV3Dump(ctx context.Context, in *IpsecSaV3Dump) (RPCService_IpsecSaV3DumpClient, error) {
247 stream, err := c.conn.NewStream(ctx)
251 x := &serviceClient_IpsecSaV3DumpClient{stream}
252 if err := x.Stream.SendMsg(in); err != nil {
255 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
261 type RPCService_IpsecSaV3DumpClient interface {
262 Recv() (*IpsecSaV3Details, error)
266 type serviceClient_IpsecSaV3DumpClient struct {
270 func (c *serviceClient_IpsecSaV3DumpClient) Recv() (*IpsecSaV3Details, error) {
271 msg, err := c.Stream.RecvMsg()
275 switch m := msg.(type) {
276 case *IpsecSaV3Details:
278 case *vpe.ControlPingReply:
279 err = c.Stream.Close()
285 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
289 func (c *serviceClient) IpsecSadEntryAddDel(ctx context.Context, in *IpsecSadEntryAddDel) (*IpsecSadEntryAddDelReply, error) {
290 out := new(IpsecSadEntryAddDelReply)
291 err := c.conn.Invoke(ctx, in, out)
295 return out, api.RetvalToVPPApiError(out.Retval)
298 func (c *serviceClient) IpsecSadEntryAddDelV2(ctx context.Context, in *IpsecSadEntryAddDelV2) (*IpsecSadEntryAddDelV2Reply, error) {
299 out := new(IpsecSadEntryAddDelV2Reply)
300 err := c.conn.Invoke(ctx, in, out)
304 return out, api.RetvalToVPPApiError(out.Retval)
307 func (c *serviceClient) IpsecSadEntryAddDelV3(ctx context.Context, in *IpsecSadEntryAddDelV3) (*IpsecSadEntryAddDelV3Reply, error) {
308 out := new(IpsecSadEntryAddDelV3Reply)
309 err := c.conn.Invoke(ctx, in, out)
313 return out, api.RetvalToVPPApiError(out.Retval)
316 func (c *serviceClient) IpsecSelectBackend(ctx context.Context, in *IpsecSelectBackend) (*IpsecSelectBackendReply, error) {
317 out := new(IpsecSelectBackendReply)
318 err := c.conn.Invoke(ctx, in, out)
322 return out, api.RetvalToVPPApiError(out.Retval)
325 func (c *serviceClient) IpsecSetAsyncMode(ctx context.Context, in *IpsecSetAsyncMode) (*IpsecSetAsyncModeReply, error) {
326 out := new(IpsecSetAsyncModeReply)
327 err := c.conn.Invoke(ctx, in, out)
331 return out, api.RetvalToVPPApiError(out.Retval)
334 func (c *serviceClient) IpsecSpdAddDel(ctx context.Context, in *IpsecSpdAddDel) (*IpsecSpdAddDelReply, error) {
335 out := new(IpsecSpdAddDelReply)
336 err := c.conn.Invoke(ctx, in, out)
340 return out, api.RetvalToVPPApiError(out.Retval)
343 func (c *serviceClient) IpsecSpdDump(ctx context.Context, in *IpsecSpdDump) (RPCService_IpsecSpdDumpClient, error) {
344 stream, err := c.conn.NewStream(ctx)
348 x := &serviceClient_IpsecSpdDumpClient{stream}
349 if err := x.Stream.SendMsg(in); err != nil {
352 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
358 type RPCService_IpsecSpdDumpClient interface {
359 Recv() (*IpsecSpdDetails, error)
363 type serviceClient_IpsecSpdDumpClient struct {
367 func (c *serviceClient_IpsecSpdDumpClient) Recv() (*IpsecSpdDetails, error) {
368 msg, err := c.Stream.RecvMsg()
372 switch m := msg.(type) {
373 case *IpsecSpdDetails:
375 case *vpe.ControlPingReply:
376 err = c.Stream.Close()
382 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
386 func (c *serviceClient) IpsecSpdEntryAddDel(ctx context.Context, in *IpsecSpdEntryAddDel) (*IpsecSpdEntryAddDelReply, error) {
387 out := new(IpsecSpdEntryAddDelReply)
388 err := c.conn.Invoke(ctx, in, out)
392 return out, api.RetvalToVPPApiError(out.Retval)
395 func (c *serviceClient) IpsecSpdInterfaceDump(ctx context.Context, in *IpsecSpdInterfaceDump) (RPCService_IpsecSpdInterfaceDumpClient, error) {
396 stream, err := c.conn.NewStream(ctx)
400 x := &serviceClient_IpsecSpdInterfaceDumpClient{stream}
401 if err := x.Stream.SendMsg(in); err != nil {
404 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
410 type RPCService_IpsecSpdInterfaceDumpClient interface {
411 Recv() (*IpsecSpdInterfaceDetails, error)
415 type serviceClient_IpsecSpdInterfaceDumpClient struct {
419 func (c *serviceClient_IpsecSpdInterfaceDumpClient) Recv() (*IpsecSpdInterfaceDetails, error) {
420 msg, err := c.Stream.RecvMsg()
424 switch m := msg.(type) {
425 case *IpsecSpdInterfaceDetails:
427 case *vpe.ControlPingReply:
428 err = c.Stream.Close()
434 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
438 func (c *serviceClient) IpsecSpdsDump(ctx context.Context, in *IpsecSpdsDump) (RPCService_IpsecSpdsDumpClient, error) {
439 stream, err := c.conn.NewStream(ctx)
443 x := &serviceClient_IpsecSpdsDumpClient{stream}
444 if err := x.Stream.SendMsg(in); err != nil {
447 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
453 type RPCService_IpsecSpdsDumpClient interface {
454 Recv() (*IpsecSpdsDetails, error)
458 type serviceClient_IpsecSpdsDumpClient struct {
462 func (c *serviceClient_IpsecSpdsDumpClient) Recv() (*IpsecSpdsDetails, error) {
463 msg, err := c.Stream.RecvMsg()
467 switch m := msg.(type) {
468 case *IpsecSpdsDetails:
470 case *vpe.ControlPingReply:
471 err = c.Stream.Close()
477 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
481 func (c *serviceClient) IpsecTunnelProtectDel(ctx context.Context, in *IpsecTunnelProtectDel) (*IpsecTunnelProtectDelReply, error) {
482 out := new(IpsecTunnelProtectDelReply)
483 err := c.conn.Invoke(ctx, in, out)
487 return out, api.RetvalToVPPApiError(out.Retval)
490 func (c *serviceClient) IpsecTunnelProtectDump(ctx context.Context, in *IpsecTunnelProtectDump) (RPCService_IpsecTunnelProtectDumpClient, error) {
491 stream, err := c.conn.NewStream(ctx)
495 x := &serviceClient_IpsecTunnelProtectDumpClient{stream}
496 if err := x.Stream.SendMsg(in); err != nil {
499 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
505 type RPCService_IpsecTunnelProtectDumpClient interface {
506 Recv() (*IpsecTunnelProtectDetails, error)
510 type serviceClient_IpsecTunnelProtectDumpClient struct {
514 func (c *serviceClient_IpsecTunnelProtectDumpClient) Recv() (*IpsecTunnelProtectDetails, error) {
515 msg, err := c.Stream.RecvMsg()
519 switch m := msg.(type) {
520 case *IpsecTunnelProtectDetails:
522 case *vpe.ControlPingReply:
523 err = c.Stream.Close()
529 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
533 func (c *serviceClient) IpsecTunnelProtectUpdate(ctx context.Context, in *IpsecTunnelProtectUpdate) (*IpsecTunnelProtectUpdateReply, error) {
534 out := new(IpsecTunnelProtectUpdateReply)
535 err := c.conn.Invoke(ctx, in, out)
539 return out, api.RetvalToVPPApiError(out.Retval)