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