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