binapi/punt/punt_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package punt
   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  punt.
  14 type RPCService interface {
  15         PuntReasonDump(ctx context.Context, in *PuntReasonDump) (RPCService_PuntReasonDumpClient, error)
  16         PuntSocketDeregister(ctx context.Context, in *PuntSocketDeregister) (*PuntSocketDeregisterReply, error)
  17         PuntSocketDump(ctx context.Context, in *PuntSocketDump) (RPCService_PuntSocketDumpClient, error)
  18         PuntSocketRegister(ctx context.Context, in *PuntSocketRegister) (*PuntSocketRegisterReply, error)
  19         SetPunt(ctx context.Context, in *SetPunt) (*SetPuntReply, error)
  20 }
  21
  22 type serviceClient struct {
  23         conn api.Connection
  24 }
  25
  26 func NewServiceClient(conn api.Connection) RPCService {
  27         return &serviceClient{conn}
  28 }
  29
  30 func (c *serviceClient) PuntReasonDump(ctx context.Context, in *PuntReasonDump) (RPCService_PuntReasonDumpClient, error) {
  31         stream, err := c.conn.NewStream(ctx)
  32         if err != nil {
  33                 return nil, err
  34         }
  35         x := &serviceClient_PuntReasonDumpClient{stream}
  36         if err := x.Stream.SendMsg(in); err != nil {
  37                 return nil, err
  38         }
  39         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  40                 return nil, err
  41         }
  42         return x, nil
  43 }
  44
  45 type RPCService_PuntReasonDumpClient interface {
  46         Recv() (*PuntReasonDetails, error)
  47         api.Stream
  48 }
  49
  50 type serviceClient_PuntReasonDumpClient struct {
  51         api.Stream
  52 }
  53
  54 func (c *serviceClient_PuntReasonDumpClient) Recv() (*PuntReasonDetails, error) {
  55         msg, err := c.Stream.RecvMsg()
  56         if err != nil {
  57                 return nil, err
  58         }
  59         switch m := msg.(type) {
  60         case *PuntReasonDetails:
  61                 return m, nil
  62         case *vpe.ControlPingReply:
  63                 return nil, io.EOF
  64         default:
  65                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  66         }
  67 }
  68
  69 func (c *serviceClient) PuntSocketDeregister(ctx context.Context, in *PuntSocketDeregister) (*PuntSocketDeregisterReply, error) {
  70         out := new(PuntSocketDeregisterReply)
  71         err := c.conn.Invoke(ctx, in, out)
  72         if err != nil {
  73                 return nil, err
  74         }
  75         return out, nil
  76 }
  77
  78 func (c *serviceClient) PuntSocketDump(ctx context.Context, in *PuntSocketDump) (RPCService_PuntSocketDumpClient, error) {
  79         stream, err := c.conn.NewStream(ctx)
  80         if err != nil {
  81                 return nil, err
  82         }
  83         x := &serviceClient_PuntSocketDumpClient{stream}
  84         if err := x.Stream.SendMsg(in); err != nil {
  85                 return nil, err
  86         }
  87         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  88                 return nil, err
  89         }
  90         return x, nil
  91 }
  92
  93 type RPCService_PuntSocketDumpClient interface {
  94         Recv() (*PuntSocketDetails, error)
  95         api.Stream
  96 }
  97
  98 type serviceClient_PuntSocketDumpClient struct {
  99         api.Stream
 100 }
 101
 102 func (c *serviceClient_PuntSocketDumpClient) Recv() (*PuntSocketDetails, error) {
 103         msg, err := c.Stream.RecvMsg()
 104         if err != nil {
 105                 return nil, err
 106         }
 107         switch m := msg.(type) {
 108         case *PuntSocketDetails:
 109                 return m, nil
 110         case *vpe.ControlPingReply:
 111                 return nil, io.EOF
 112         default:
 113                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 114         }
 115 }
 116
 117 func (c *serviceClient) PuntSocketRegister(ctx context.Context, in *PuntSocketRegister) (*PuntSocketRegisterReply, error) {
 118         out := new(PuntSocketRegisterReply)
 119         err := c.conn.Invoke(ctx, in, out)
 120         if err != nil {
 121                 return nil, err
 122         }
 123         return out, nil
 124 }
 125
 126 func (c *serviceClient) SetPunt(ctx context.Context, in *SetPunt) (*SetPuntReply, error) {
 127         out := new(SetPuntReply)
 128         err := c.conn.Invoke(ctx, in, out)
 129         if err != nil {
 130                 return nil, err
 131         }
 132         return out, nil
 133 }