binapi/dhcp/dhcp_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package dhcp
   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  dhcp.
  14 type RPCService interface {
  15         DHCP6ClientsEnableDisable(ctx context.Context, in *DHCP6ClientsEnableDisable) (*DHCP6ClientsEnableDisableReply, error)
  16         DHCP6DuidLlSet(ctx context.Context, in *DHCP6DuidLlSet) (*DHCP6DuidLlSetReply, error)
  17         DHCP6PdSendClientMessage(ctx context.Context, in *DHCP6PdSendClientMessage) (*DHCP6PdSendClientMessageReply, error)
  18         DHCP6SendClientMessage(ctx context.Context, in *DHCP6SendClientMessage) (*DHCP6SendClientMessageReply, error)
  19         DHCPClientConfig(ctx context.Context, in *DHCPClientConfig) (*DHCPClientConfigReply, error)
  20         DHCPClientDump(ctx context.Context, in *DHCPClientDump) (RPCService_DHCPClientDumpClient, error)
  21         DHCPPluginControlPing(ctx context.Context, in *DHCPPluginControlPing) (*DHCPPluginControlPingReply, error)
  22         DHCPPluginGetVersion(ctx context.Context, in *DHCPPluginGetVersion) (*DHCPPluginGetVersionReply, error)
  23         DHCPProxyConfig(ctx context.Context, in *DHCPProxyConfig) (*DHCPProxyConfigReply, error)
  24         DHCPProxyDump(ctx context.Context, in *DHCPProxyDump) (RPCService_DHCPProxyDumpClient, error)
  25         DHCPProxySetVss(ctx context.Context, in *DHCPProxySetVss) (*DHCPProxySetVssReply, error)
  26         WantDHCP6PdReplyEvents(ctx context.Context, in *WantDHCP6PdReplyEvents) (*WantDHCP6PdReplyEventsReply, error)
  27         WantDHCP6ReplyEvents(ctx context.Context, in *WantDHCP6ReplyEvents) (*WantDHCP6ReplyEventsReply, error)
  28 }
  29
  30 type serviceClient struct {
  31         conn api.Connection
  32 }
  33
  34 func NewServiceClient(conn api.Connection) RPCService {
  35         return &serviceClient{conn}
  36 }
  37
  38 func (c *serviceClient) DHCP6ClientsEnableDisable(ctx context.Context, in *DHCP6ClientsEnableDisable) (*DHCP6ClientsEnableDisableReply, error) {
  39         out := new(DHCP6ClientsEnableDisableReply)
  40         err := c.conn.Invoke(ctx, in, out)
  41         if err != nil {
  42                 return nil, err
  43         }
  44         return out, nil
  45 }
  46
  47 func (c *serviceClient) DHCP6DuidLlSet(ctx context.Context, in *DHCP6DuidLlSet) (*DHCP6DuidLlSetReply, error) {
  48         out := new(DHCP6DuidLlSetReply)
  49         err := c.conn.Invoke(ctx, in, out)
  50         if err != nil {
  51                 return nil, err
  52         }
  53         return out, nil
  54 }
  55
  56 func (c *serviceClient) DHCP6PdSendClientMessage(ctx context.Context, in *DHCP6PdSendClientMessage) (*DHCP6PdSendClientMessageReply, error) {
  57         out := new(DHCP6PdSendClientMessageReply)
  58         err := c.conn.Invoke(ctx, in, out)
  59         if err != nil {
  60                 return nil, err
  61         }
  62         return out, nil
  63 }
  64
  65 func (c *serviceClient) DHCP6SendClientMessage(ctx context.Context, in *DHCP6SendClientMessage) (*DHCP6SendClientMessageReply, error) {
  66         out := new(DHCP6SendClientMessageReply)
  67         err := c.conn.Invoke(ctx, in, out)
  68         if err != nil {
  69                 return nil, err
  70         }
  71         return out, nil
  72 }
  73
  74 func (c *serviceClient) DHCPClientConfig(ctx context.Context, in *DHCPClientConfig) (*DHCPClientConfigReply, error) {
  75         out := new(DHCPClientConfigReply)
  76         err := c.conn.Invoke(ctx, in, out)
  77         if err != nil {
  78                 return nil, err
  79         }
  80         return out, nil
  81 }
  82
  83 func (c *serviceClient) DHCPClientDump(ctx context.Context, in *DHCPClientDump) (RPCService_DHCPClientDumpClient, error) {
  84         stream, err := c.conn.NewStream(ctx)
  85         if err != nil {
  86                 return nil, err
  87         }
  88         x := &serviceClient_DHCPClientDumpClient{stream}
  89         if err := x.Stream.SendMsg(in); err != nil {
  90                 return nil, err
  91         }
  92         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  93                 return nil, err
  94         }
  95         return x, nil
  96 }
  97
  98 type RPCService_DHCPClientDumpClient interface {
  99         Recv() (*DHCPClientDetails, error)
 100         api.Stream
 101 }
 102
 103 type serviceClient_DHCPClientDumpClient struct {
 104         api.Stream
 105 }
 106
 107 func (c *serviceClient_DHCPClientDumpClient) Recv() (*DHCPClientDetails, error) {
 108         msg, err := c.Stream.RecvMsg()
 109         if err != nil {
 110                 return nil, err
 111         }
 112         switch m := msg.(type) {
 113         case *DHCPClientDetails:
 114                 return m, nil
 115         case *vpe.ControlPingReply:
 116                 return nil, io.EOF
 117         default:
 118                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 119         }
 120 }
 121
 122 func (c *serviceClient) DHCPPluginControlPing(ctx context.Context, in *DHCPPluginControlPing) (*DHCPPluginControlPingReply, error) {
 123         out := new(DHCPPluginControlPingReply)
 124         err := c.conn.Invoke(ctx, in, out)
 125         if err != nil {
 126                 return nil, err
 127         }
 128         return out, nil
 129 }
 130
 131 func (c *serviceClient) DHCPPluginGetVersion(ctx context.Context, in *DHCPPluginGetVersion) (*DHCPPluginGetVersionReply, error) {
 132         out := new(DHCPPluginGetVersionReply)
 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) DHCPProxyConfig(ctx context.Context, in *DHCPProxyConfig) (*DHCPProxyConfigReply, error) {
 141         out := new(DHCPProxyConfigReply)
 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) DHCPProxyDump(ctx context.Context, in *DHCPProxyDump) (RPCService_DHCPProxyDumpClient, error) {
 150         stream, err := c.conn.NewStream(ctx)
 151         if err != nil {
 152                 return nil, err
 153         }
 154         x := &serviceClient_DHCPProxyDumpClient{stream}
 155         if err := x.Stream.SendMsg(in); err != nil {
 156                 return nil, err
 157         }
 158         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 159                 return nil, err
 160         }
 161         return x, nil
 162 }
 163
 164 type RPCService_DHCPProxyDumpClient interface {
 165         Recv() (*DHCPProxyDetails, error)
 166         api.Stream
 167 }
 168
 169 type serviceClient_DHCPProxyDumpClient struct {
 170         api.Stream
 171 }
 172
 173 func (c *serviceClient_DHCPProxyDumpClient) Recv() (*DHCPProxyDetails, error) {
 174         msg, err := c.Stream.RecvMsg()
 175         if err != nil {
 176                 return nil, err
 177         }
 178         switch m := msg.(type) {
 179         case *DHCPProxyDetails:
 180                 return m, nil
 181         case *vpe.ControlPingReply:
 182                 return nil, io.EOF
 183         default:
 184                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 185         }
 186 }
 187
 188 func (c *serviceClient) DHCPProxySetVss(ctx context.Context, in *DHCPProxySetVss) (*DHCPProxySetVssReply, error) {
 189         out := new(DHCPProxySetVssReply)
 190         err := c.conn.Invoke(ctx, in, out)
 191         if err != nil {
 192                 return nil, err
 193         }
 194         return out, nil
 195 }
 196
 197 func (c *serviceClient) WantDHCP6PdReplyEvents(ctx context.Context, in *WantDHCP6PdReplyEvents) (*WantDHCP6PdReplyEventsReply, error) {
 198         out := new(WantDHCP6PdReplyEventsReply)
 199         err := c.conn.Invoke(ctx, in, out)
 200         if err != nil {
 201                 return nil, err
 202         }
 203         return out, nil
 204 }
 205
 206 func (c *serviceClient) WantDHCP6ReplyEvents(ctx context.Context, in *WantDHCP6ReplyEvents) (*WantDHCP6ReplyEventsReply, error) {
 207         out := new(WantDHCP6ReplyEventsReply)
 208         err := c.conn.Invoke(ctx, in, out)
 209         if err != nil {
 210                 return nil, err
 211         }
 212         return out, nil
 213 }