internal/testbinapi/binapi2001/af_packet/af_packet_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package af_packet
   4
   5 import (
   6         "context"
   7         "io"
   8
   9         api "git.fd.io/govpp.git/api"
  10 )
  11
  12 // RPCService represents RPC service API for af_packet module.
  13 type RPCService interface {
  14         DumpAfPacket(ctx context.Context, in *AfPacketDump) (RPCService_DumpAfPacketClient, error)
  15         AfPacketCreate(ctx context.Context, in *AfPacketCreate) (*AfPacketCreateReply, error)
  16         AfPacketDelete(ctx context.Context, in *AfPacketDelete) (*AfPacketDeleteReply, error)
  17         AfPacketSetL4CksumOffload(ctx context.Context, in *AfPacketSetL4CksumOffload) (*AfPacketSetL4CksumOffloadReply, error)
  18 }
  19
  20 type serviceClient struct {
  21         ch api.Channel
  22 }
  23
  24 func NewServiceClient(ch api.Channel) RPCService {
  25         return &serviceClient{ch}
  26 }
  27
  28 func (c *serviceClient) DumpAfPacket(ctx context.Context, in *AfPacketDump) (RPCService_DumpAfPacketClient, error) {
  29         stream := c.ch.SendMultiRequest(in)
  30         x := &serviceClient_DumpAfPacketClient{stream}
  31         return x, nil
  32 }
  33
  34 type RPCService_DumpAfPacketClient interface {
  35         Recv() (*AfPacketDetails, error)
  36 }
  37
  38 type serviceClient_DumpAfPacketClient struct {
  39         api.MultiRequestCtx
  40 }
  41
  42 func (c *serviceClient_DumpAfPacketClient) Recv() (*AfPacketDetails, error) {
  43         m := new(AfPacketDetails)
  44         stop, err := c.MultiRequestCtx.ReceiveReply(m)
  45         if err != nil {
  46                 return nil, err
  47         }
  48         if stop {
  49                 return nil, io.EOF
  50         }
  51         return m, nil
  52 }
  53
  54 func (c *serviceClient) AfPacketCreate(ctx context.Context, in *AfPacketCreate) (*AfPacketCreateReply, error) {
  55         out := new(AfPacketCreateReply)
  56         err := c.ch.SendRequest(in).ReceiveReply(out)
  57         if err != nil {
  58                 return nil, err
  59         }
  60         return out, nil
  61 }
  62
  63 func (c *serviceClient) AfPacketDelete(ctx context.Context, in *AfPacketDelete) (*AfPacketDeleteReply, error) {
  64         out := new(AfPacketDeleteReply)
  65         err := c.ch.SendRequest(in).ReceiveReply(out)
  66         if err != nil {
  67                 return nil, err
  68         }
  69         return out, nil
  70 }
  71
  72 func (c *serviceClient) AfPacketSetL4CksumOffload(ctx context.Context, in *AfPacketSetL4CksumOffload) (*AfPacketSetL4CksumOffloadReply, error) {
  73         out := new(AfPacketSetL4CksumOffloadReply)
  74         err := c.ch.SendRequest(in).ReceiveReply(out)
  75         if err != nil {
  76                 return nil, err
  77         }
  78         return out, nil
  79 }
  80
  81 // Reference imports to suppress errors if they are not otherwise used.
  82 var _ = api.RegisterMessage
  83 var _ = context.Background
  84 var _ = io.Copy