binapi/igmp/igmp_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package igmp
   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  igmp.
  15 type RPCService interface {
  16         IgmpClearInterface(ctx context.Context, in *IgmpClearInterface) (*IgmpClearInterfaceReply, error)
  17         IgmpDump(ctx context.Context, in *IgmpDump) (RPCService_IgmpDumpClient, error)
  18         IgmpEnableDisable(ctx context.Context, in *IgmpEnableDisable) (*IgmpEnableDisableReply, error)
  19         IgmpGroupPrefixDump(ctx context.Context, in *IgmpGroupPrefixDump) (RPCService_IgmpGroupPrefixDumpClient, error)
  20         IgmpGroupPrefixSet(ctx context.Context, in *IgmpGroupPrefixSet) (*IgmpGroupPrefixSetReply, error)
  21         IgmpListen(ctx context.Context, in *IgmpListen) (*IgmpListenReply, error)
  22         IgmpProxyDeviceAddDel(ctx context.Context, in *IgmpProxyDeviceAddDel) (*IgmpProxyDeviceAddDelReply, error)
  23         IgmpProxyDeviceAddDelInterface(ctx context.Context, in *IgmpProxyDeviceAddDelInterface) (*IgmpProxyDeviceAddDelInterfaceReply, error)
  24         WantIgmpEvents(ctx context.Context, in *WantIgmpEvents) (*WantIgmpEventsReply, 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) IgmpClearInterface(ctx context.Context, in *IgmpClearInterface) (*IgmpClearInterfaceReply, error) {
  36         out := new(IgmpClearInterfaceReply)
  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) IgmpDump(ctx context.Context, in *IgmpDump) (RPCService_IgmpDumpClient, error) {
  45         stream, err := c.conn.NewStream(ctx)
  46         if err != nil {
  47                 return nil, err
  48         }
  49         x := &serviceClient_IgmpDumpClient{stream}
  50         if err := x.Stream.SendMsg(in); err != nil {
  51                 return nil, err
  52         }
  53         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  54                 return nil, err
  55         }
  56         return x, nil
  57 }
  58
  59 type RPCService_IgmpDumpClient interface {
  60         Recv() (*IgmpDetails, error)
  61         api.Stream
  62 }
  63
  64 type serviceClient_IgmpDumpClient struct {
  65         api.Stream
  66 }
  67
  68 func (c *serviceClient_IgmpDumpClient) Recv() (*IgmpDetails, error) {
  69         msg, err := c.Stream.RecvMsg()
  70         if err != nil {
  71                 return nil, err
  72         }
  73         switch m := msg.(type) {
  74         case *IgmpDetails:
  75                 return m, nil
  76         case *vpe.ControlPingReply:
  77                 return nil, io.EOF
  78         default:
  79                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  80         }
  81 }
  82
  83 func (c *serviceClient) IgmpEnableDisable(ctx context.Context, in *IgmpEnableDisable) (*IgmpEnableDisableReply, error) {
  84         out := new(IgmpEnableDisableReply)
  85         err := c.conn.Invoke(ctx, in, out)
  86         if err != nil {
  87                 return nil, err
  88         }
  89         return out, nil
  90 }
  91
  92 func (c *serviceClient) IgmpGroupPrefixDump(ctx context.Context, in *IgmpGroupPrefixDump) (RPCService_IgmpGroupPrefixDumpClient, error) {
  93         stream, err := c.conn.NewStream(ctx)
  94         if err != nil {
  95                 return nil, err
  96         }
  97         x := &serviceClient_IgmpGroupPrefixDumpClient{stream}
  98         if err := x.Stream.SendMsg(in); err != nil {
  99                 return nil, err
 100         }
 101         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 102                 return nil, err
 103         }
 104         return x, nil
 105 }
 106
 107 type RPCService_IgmpGroupPrefixDumpClient interface {
 108         Recv() (*IgmpGroupPrefixDetails, error)
 109         api.Stream
 110 }
 111
 112 type serviceClient_IgmpGroupPrefixDumpClient struct {
 113         api.Stream
 114 }
 115
 116 func (c *serviceClient_IgmpGroupPrefixDumpClient) Recv() (*IgmpGroupPrefixDetails, error) {
 117         msg, err := c.Stream.RecvMsg()
 118         if err != nil {
 119                 return nil, err
 120         }
 121         switch m := msg.(type) {
 122         case *IgmpGroupPrefixDetails:
 123                 return m, nil
 124         case *vpe.ControlPingReply:
 125                 return nil, io.EOF
 126         default:
 127                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 128         }
 129 }
 130
 131 func (c *serviceClient) IgmpGroupPrefixSet(ctx context.Context, in *IgmpGroupPrefixSet) (*IgmpGroupPrefixSetReply, error) {
 132         out := new(IgmpGroupPrefixSetReply)
 133         err := c.conn.Invoke(ctx, in, out)
 134         if err != nil {
 135                 return nil, err
 136         }
 137         return out, nil
 138 }
 139
 140 func (c *serviceClient) IgmpListen(ctx context.Context, in *IgmpListen) (*IgmpListenReply, error) {
 141         out := new(IgmpListenReply)
 142         err := c.conn.Invoke(ctx, in, out)
 143         if err != nil {
 144                 return nil, err
 145         }
 146         return out, nil
 147 }
 148
 149 func (c *serviceClient) IgmpProxyDeviceAddDel(ctx context.Context, in *IgmpProxyDeviceAddDel) (*IgmpProxyDeviceAddDelReply, error) {
 150         out := new(IgmpProxyDeviceAddDelReply)
 151         err := c.conn.Invoke(ctx, in, out)
 152         if err != nil {
 153                 return nil, err
 154         }
 155         return out, nil
 156 }
 157
 158 func (c *serviceClient) IgmpProxyDeviceAddDelInterface(ctx context.Context, in *IgmpProxyDeviceAddDelInterface) (*IgmpProxyDeviceAddDelInterfaceReply, error) {
 159         out := new(IgmpProxyDeviceAddDelInterfaceReply)
 160         err := c.conn.Invoke(ctx, in, out)
 161         if err != nil {
 162                 return nil, err
 163         }
 164         return out, nil
 165 }
 166
 167 func (c *serviceClient) WantIgmpEvents(ctx context.Context, in *WantIgmpEvents) (*WantIgmpEventsReply, error) {
 168         out := new(WantIgmpEventsReply)
 169         err := c.conn.Invoke(ctx, in, out)
 170         if err != nil {
 171                 return nil, err
 172         }
 173         return out, nil
 174 }