binapi/ip6_nd/ip6_nd_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package ip6_nd
   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  ip6_nd.
  14 type RPCService interface {
  15         IP6ndProxyAddDel(ctx context.Context, in *IP6ndProxyAddDel) (*IP6ndProxyAddDelReply, error)
  16         IP6ndProxyDump(ctx context.Context, in *IP6ndProxyDump) (RPCService_IP6ndProxyDumpClient, error)
  17         IP6ndSendRouterSolicitation(ctx context.Context, in *IP6ndSendRouterSolicitation) (*IP6ndSendRouterSolicitationReply, error)
  18         SwInterfaceIP6ndRaConfig(ctx context.Context, in *SwInterfaceIP6ndRaConfig) (*SwInterfaceIP6ndRaConfigReply, error)
  19         SwInterfaceIP6ndRaPrefix(ctx context.Context, in *SwInterfaceIP6ndRaPrefix) (*SwInterfaceIP6ndRaPrefixReply, error)
  20         WantIP6RaEvents(ctx context.Context, in *WantIP6RaEvents) (*WantIP6RaEventsReply, 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) IP6ndProxyAddDel(ctx context.Context, in *IP6ndProxyAddDel) (*IP6ndProxyAddDelReply, error) {
  32         out := new(IP6ndProxyAddDelReply)
  33         err := c.conn.Invoke(ctx, in, out)
  34         if err != nil {
  35                 return nil, err
  36         }
  37         return out, nil
  38 }
  39
  40 func (c *serviceClient) IP6ndProxyDump(ctx context.Context, in *IP6ndProxyDump) (RPCService_IP6ndProxyDumpClient, error) {
  41         stream, err := c.conn.NewStream(ctx)
  42         if err != nil {
  43                 return nil, err
  44         }
  45         x := &serviceClient_IP6ndProxyDumpClient{stream}
  46         if err := x.Stream.SendMsg(in); err != nil {
  47                 return nil, err
  48         }
  49         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  50                 return nil, err
  51         }
  52         return x, nil
  53 }
  54
  55 type RPCService_IP6ndProxyDumpClient interface {
  56         Recv() (*IP6ndProxyDetails, error)
  57         api.Stream
  58 }
  59
  60 type serviceClient_IP6ndProxyDumpClient struct {
  61         api.Stream
  62 }
  63
  64 func (c *serviceClient_IP6ndProxyDumpClient) Recv() (*IP6ndProxyDetails, error) {
  65         msg, err := c.Stream.RecvMsg()
  66         if err != nil {
  67                 return nil, err
  68         }
  69         switch m := msg.(type) {
  70         case *IP6ndProxyDetails:
  71                 return m, nil
  72         case *vpe.ControlPingReply:
  73                 return nil, io.EOF
  74         default:
  75                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  76         }
  77 }
  78
  79 func (c *serviceClient) IP6ndSendRouterSolicitation(ctx context.Context, in *IP6ndSendRouterSolicitation) (*IP6ndSendRouterSolicitationReply, error) {
  80         out := new(IP6ndSendRouterSolicitationReply)
  81         err := c.conn.Invoke(ctx, in, out)
  82         if err != nil {
  83                 return nil, err
  84         }
  85         return out, nil
  86 }
  87
  88 func (c *serviceClient) SwInterfaceIP6ndRaConfig(ctx context.Context, in *SwInterfaceIP6ndRaConfig) (*SwInterfaceIP6ndRaConfigReply, error) {
  89         out := new(SwInterfaceIP6ndRaConfigReply)
  90         err := c.conn.Invoke(ctx, in, out)
  91         if err != nil {
  92                 return nil, err
  93         }
  94         return out, nil
  95 }
  96
  97 func (c *serviceClient) SwInterfaceIP6ndRaPrefix(ctx context.Context, in *SwInterfaceIP6ndRaPrefix) (*SwInterfaceIP6ndRaPrefixReply, error) {
  98         out := new(SwInterfaceIP6ndRaPrefixReply)
  99         err := c.conn.Invoke(ctx, in, out)
 100         if err != nil {
 101                 return nil, err
 102         }
 103         return out, nil
 104 }
 105
 106 func (c *serviceClient) WantIP6RaEvents(ctx context.Context, in *WantIP6RaEvents) (*WantIP6RaEventsReply, error) {
 107         out := new(WantIP6RaEventsReply)
 108         err := c.conn.Invoke(ctx, in, out)
 109         if err != nil {
 110                 return nil, err
 111         }
 112         return out, nil
 113 }