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