binapi/lisp_gpe/lisp_gpe_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package lisp_gpe
   4
   5 import (
   6         "context"
   7         "fmt"
   8         "io"
   9
  10         api "git.fd.io/govpp.git/api"
  11         vpe "git.fd.io/govpp.git/binapi/vpe"
  12 )
  13
  14 // RPCService defines RPC service  lisp_gpe.
  15 type RPCService interface {
  16         GpeAddDelFwdEntry(ctx context.Context, in *GpeAddDelFwdEntry) (*GpeAddDelFwdEntryReply, error)
  17         GpeAddDelIface(ctx context.Context, in *GpeAddDelIface) (*GpeAddDelIfaceReply, error)
  18         GpeAddDelNativeFwdRpath(ctx context.Context, in *GpeAddDelNativeFwdRpath) (*GpeAddDelNativeFwdRpathReply, error)
  19         GpeEnableDisable(ctx context.Context, in *GpeEnableDisable) (*GpeEnableDisableReply, error)
  20         GpeFwdEntriesGet(ctx context.Context, in *GpeFwdEntriesGet) (*GpeFwdEntriesGetReply, error)
  21         GpeFwdEntryPathDump(ctx context.Context, in *GpeFwdEntryPathDump) (RPCService_GpeFwdEntryPathDumpClient, error)
  22         GpeFwdEntryVnisGet(ctx context.Context, in *GpeFwdEntryVnisGet) (*GpeFwdEntryVnisGetReply, error)
  23         GpeGetEncapMode(ctx context.Context, in *GpeGetEncapMode) (*GpeGetEncapModeReply, error)
  24         GpeNativeFwdRpathsGet(ctx context.Context, in *GpeNativeFwdRpathsGet) (*GpeNativeFwdRpathsGetReply, error)
  25         GpeSetEncapMode(ctx context.Context, in *GpeSetEncapMode) (*GpeSetEncapModeReply, error)
  26 }
  27
  28 type serviceClient struct {
  29         conn api.Connection
  30 }
  31
  32 func NewServiceClient(conn api.Connection) RPCService {
  33         return &serviceClient{conn}
  34 }
  35
  36 func (c *serviceClient) GpeAddDelFwdEntry(ctx context.Context, in *GpeAddDelFwdEntry) (*GpeAddDelFwdEntryReply, error) {
  37         out := new(GpeAddDelFwdEntryReply)
  38         err := c.conn.Invoke(ctx, in, out)
  39         if err != nil {
  40                 return nil, err
  41         }
  42         return out, nil
  43 }
  44
  45 func (c *serviceClient) GpeAddDelIface(ctx context.Context, in *GpeAddDelIface) (*GpeAddDelIfaceReply, error) {
  46         out := new(GpeAddDelIfaceReply)
  47         err := c.conn.Invoke(ctx, in, out)
  48         if err != nil {
  49                 return nil, err
  50         }
  51         return out, nil
  52 }
  53
  54 func (c *serviceClient) GpeAddDelNativeFwdRpath(ctx context.Context, in *GpeAddDelNativeFwdRpath) (*GpeAddDelNativeFwdRpathReply, error) {
  55         out := new(GpeAddDelNativeFwdRpathReply)
  56         err := c.conn.Invoke(ctx, in, out)
  57         if err != nil {
  58                 return nil, err
  59         }
  60         return out, nil
  61 }
  62
  63 func (c *serviceClient) GpeEnableDisable(ctx context.Context, in *GpeEnableDisable) (*GpeEnableDisableReply, error) {
  64         out := new(GpeEnableDisableReply)
  65         err := c.conn.Invoke(ctx, in, out)
  66         if err != nil {
  67                 return nil, err
  68         }
  69         return out, nil
  70 }
  71
  72 func (c *serviceClient) GpeFwdEntriesGet(ctx context.Context, in *GpeFwdEntriesGet) (*GpeFwdEntriesGetReply, error) {
  73         out := new(GpeFwdEntriesGetReply)
  74         err := c.conn.Invoke(ctx, in, out)
  75         if err != nil {
  76                 return nil, err
  77         }
  78         return out, nil
  79 }
  80
  81 func (c *serviceClient) GpeFwdEntryPathDump(ctx context.Context, in *GpeFwdEntryPathDump) (RPCService_GpeFwdEntryPathDumpClient, error) {
  82         stream, err := c.conn.NewStream(ctx)
  83         if err != nil {
  84                 return nil, err
  85         }
  86         x := &serviceClient_GpeFwdEntryPathDumpClient{stream}
  87         if err := x.Stream.SendMsg(in); err != nil {
  88                 return nil, err
  89         }
  90         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  91                 return nil, err
  92         }
  93         return x, nil
  94 }
  95
  96 type RPCService_GpeFwdEntryPathDumpClient interface {
  97         Recv() (*GpeFwdEntryPathDetails, error)
  98         api.Stream
  99 }
 100
 101 type serviceClient_GpeFwdEntryPathDumpClient struct {
 102         api.Stream
 103 }
 104
 105 func (c *serviceClient_GpeFwdEntryPathDumpClient) Recv() (*GpeFwdEntryPathDetails, error) {
 106         msg, err := c.Stream.RecvMsg()
 107         if err != nil {
 108                 return nil, err
 109         }
 110         switch m := msg.(type) {
 111         case *GpeFwdEntryPathDetails:
 112                 return m, nil
 113         case *vpe.ControlPingReply:
 114                 return nil, io.EOF
 115         default:
 116                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 117         }
 118 }
 119
 120 func (c *serviceClient) GpeFwdEntryVnisGet(ctx context.Context, in *GpeFwdEntryVnisGet) (*GpeFwdEntryVnisGetReply, error) {
 121         out := new(GpeFwdEntryVnisGetReply)
 122         err := c.conn.Invoke(ctx, in, out)
 123         if err != nil {
 124                 return nil, err
 125         }
 126         return out, nil
 127 }
 128
 129 func (c *serviceClient) GpeGetEncapMode(ctx context.Context, in *GpeGetEncapMode) (*GpeGetEncapModeReply, error) {
 130         out := new(GpeGetEncapModeReply)
 131         err := c.conn.Invoke(ctx, in, out)
 132         if err != nil {
 133                 return nil, err
 134         }
 135         return out, nil
 136 }
 137
 138 func (c *serviceClient) GpeNativeFwdRpathsGet(ctx context.Context, in *GpeNativeFwdRpathsGet) (*GpeNativeFwdRpathsGetReply, error) {
 139         out := new(GpeNativeFwdRpathsGetReply)
 140         err := c.conn.Invoke(ctx, in, out)
 141         if err != nil {
 142                 return nil, err
 143         }
 144         return out, nil
 145 }
 146
 147 func (c *serviceClient) GpeSetEncapMode(ctx context.Context, in *GpeSetEncapMode) (*GpeSetEncapModeReply, error) {
 148         out := new(GpeSetEncapModeReply)
 149         err := c.conn.Invoke(ctx, in, out)
 150         if err != nil {
 151                 return nil, err
 152         }
 153         return out, nil
 154 }