binapi/pnat/pnat_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package pnat
   4
   5 import (
   6         "context"
   7         "fmt"
   8         "io"
   9
  10         api "git.fd.io/govpp.git/api"
  11 )
  12
  13 // RPCService defines RPC service pnat.
  14 type RPCService interface {
  15         PnatBindingAdd(ctx context.Context, in *PnatBindingAdd) (*PnatBindingAddReply, error)
  16         PnatBindingAttach(ctx context.Context, in *PnatBindingAttach) (*PnatBindingAttachReply, error)
  17         PnatBindingDel(ctx context.Context, in *PnatBindingDel) (*PnatBindingDelReply, error)
  18         PnatBindingDetach(ctx context.Context, in *PnatBindingDetach) (*PnatBindingDetachReply, error)
  19         PnatBindingsGet(ctx context.Context, in *PnatBindingsGet) (RPCService_PnatBindingsGetClient, error)
  20         PnatInterfacesGet(ctx context.Context, in *PnatInterfacesGet) (RPCService_PnatInterfacesGetClient, error)
  21 }
  22
  23 type serviceClient struct {
  24         conn api.Connection
  25 }
  26
  27 func NewServiceClient(conn api.Connection) RPCService {
  28         return &serviceClient{conn}
  29 }
  30
  31 func (c *serviceClient) PnatBindingAdd(ctx context.Context, in *PnatBindingAdd) (*PnatBindingAddReply, error) {
  32         out := new(PnatBindingAddReply)
  33         err := c.conn.Invoke(ctx, in, out)
  34         if err != nil {
  35                 return nil, err
  36         }
  37         return out, api.RetvalToVPPApiError(out.Retval)
  38 }
  39
  40 func (c *serviceClient) PnatBindingAttach(ctx context.Context, in *PnatBindingAttach) (*PnatBindingAttachReply, error) {
  41         out := new(PnatBindingAttachReply)
  42         err := c.conn.Invoke(ctx, in, out)
  43         if err != nil {
  44                 return nil, err
  45         }
  46         return out, api.RetvalToVPPApiError(out.Retval)
  47 }
  48
  49 func (c *serviceClient) PnatBindingDel(ctx context.Context, in *PnatBindingDel) (*PnatBindingDelReply, error) {
  50         out := new(PnatBindingDelReply)
  51         err := c.conn.Invoke(ctx, in, out)
  52         if err != nil {
  53                 return nil, err
  54         }
  55         return out, api.RetvalToVPPApiError(out.Retval)
  56 }
  57
  58 func (c *serviceClient) PnatBindingDetach(ctx context.Context, in *PnatBindingDetach) (*PnatBindingDetachReply, error) {
  59         out := new(PnatBindingDetachReply)
  60         err := c.conn.Invoke(ctx, in, out)
  61         if err != nil {
  62                 return nil, err
  63         }
  64         return out, api.RetvalToVPPApiError(out.Retval)
  65 }
  66
  67 func (c *serviceClient) PnatBindingsGet(ctx context.Context, in *PnatBindingsGet) (RPCService_PnatBindingsGetClient, error) {
  68         stream, err := c.conn.NewStream(ctx)
  69         if err != nil {
  70                 return nil, err
  71         }
  72         x := &serviceClient_PnatBindingsGetClient{stream}
  73         if err := x.Stream.SendMsg(in); err != nil {
  74                 return nil, err
  75         }
  76         return x, nil
  77 }
  78
  79 type RPCService_PnatBindingsGetClient interface {
  80         Recv() (*PnatBindingsDetails, error)
  81         api.Stream
  82 }
  83
  84 type serviceClient_PnatBindingsGetClient struct {
  85         api.Stream
  86 }
  87
  88 func (c *serviceClient_PnatBindingsGetClient) Recv() (*PnatBindingsDetails, error) {
  89         msg, err := c.Stream.RecvMsg()
  90         if err != nil {
  91                 return nil, err
  92         }
  93         switch m := msg.(type) {
  94         case *PnatBindingsDetails:
  95                 return m, nil
  96         case *PnatBindingsGetReply:
  97                 return nil, io.EOF
  98         default:
  99                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 100         }
 101 }
 102
 103 func (c *serviceClient) PnatInterfacesGet(ctx context.Context, in *PnatInterfacesGet) (RPCService_PnatInterfacesGetClient, error) {
 104         stream, err := c.conn.NewStream(ctx)
 105         if err != nil {
 106                 return nil, err
 107         }
 108         x := &serviceClient_PnatInterfacesGetClient{stream}
 109         if err := x.Stream.SendMsg(in); err != nil {
 110                 return nil, err
 111         }
 112         return x, nil
 113 }
 114
 115 type RPCService_PnatInterfacesGetClient interface {
 116         Recv() (*PnatInterfacesDetails, error)
 117         api.Stream
 118 }
 119
 120 type serviceClient_PnatInterfacesGetClient struct {
 121         api.Stream
 122 }
 123
 124 func (c *serviceClient_PnatInterfacesGetClient) Recv() (*PnatInterfacesDetails, error) {
 125         msg, err := c.Stream.RecvMsg()
 126         if err != nil {
 127                 return nil, err
 128         }
 129         switch m := msg.(type) {
 130         case *PnatInterfacesDetails:
 131                 return m, nil
 132         case *PnatInterfacesGetReply:
 133                 return nil, io.EOF
 134         default:
 135                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 136         }
 137 }