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 "go.fd.io/govpp/api"
  11         memclnt "go.fd.io/govpp/binapi/memclnt"
  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, api.RetvalToVPPApiError(out.Retval)
  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, api.RetvalToVPPApiError(out.Retval)
  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, api.RetvalToVPPApiError(out.Retval)
  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, api.RetvalToVPPApiError(out.Retval)
  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, api.RetvalToVPPApiError(out.Retval)
  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(&memclnt.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 *memclnt.ControlPingReply:
 117                 err = c.Stream.Close()
 118                 if err != nil {
 119                         return nil, err
 120                 }
 121                 return nil, io.EOF
 122         default:
 123                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 124         }
 125 }
 126
 127 func (c *serviceClient) DHCPPluginControlPing(ctx context.Context, in *DHCPPluginControlPing) (*DHCPPluginControlPingReply, error) {
 128         out := new(DHCPPluginControlPingReply)
 129         err := c.conn.Invoke(ctx, in, out)
 130         if err != nil {
 131                 return nil, err
 132         }
 133         return out, api.RetvalToVPPApiError(out.Retval)
 134 }
 135
 136 func (c *serviceClient) DHCPPluginGetVersion(ctx context.Context, in *DHCPPluginGetVersion) (*DHCPPluginGetVersionReply, error) {
 137         out := new(DHCPPluginGetVersionReply)
 138         err := c.conn.Invoke(ctx, in, out)
 139         if err != nil {
 140                 return nil, err
 141         }
 142         return out, nil
 143 }
 144
 145 func (c *serviceClient) DHCPProxyConfig(ctx context.Context, in *DHCPProxyConfig) (*DHCPProxyConfigReply, error) {
 146         out := new(DHCPProxyConfigReply)
 147         err := c.conn.Invoke(ctx, in, out)
 148         if err != nil {
 149                 return nil, err
 150         }
 151         return out, api.RetvalToVPPApiError(out.Retval)
 152 }
 153
 154 func (c *serviceClient) DHCPProxyDump(ctx context.Context, in *DHCPProxyDump) (RPCService_DHCPProxyDumpClient, error) {
 155         stream, err := c.conn.NewStream(ctx)
 156         if err != nil {
 157                 return nil, err
 158         }
 159         x := &serviceClient_DHCPProxyDumpClient{stream}
 160         if err := x.Stream.SendMsg(in); err != nil {
 161                 return nil, err
 162         }
 163         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 164                 return nil, err
 165         }
 166         return x, nil
 167 }
 168
 169 type RPCService_DHCPProxyDumpClient interface {
 170         Recv() (*DHCPProxyDetails, error)
 171         api.Stream
 172 }
 173
 174 type serviceClient_DHCPProxyDumpClient struct {
 175         api.Stream
 176 }
 177
 178 func (c *serviceClient_DHCPProxyDumpClient) Recv() (*DHCPProxyDetails, error) {
 179         msg, err := c.Stream.RecvMsg()
 180         if err != nil {
 181                 return nil, err
 182         }
 183         switch m := msg.(type) {
 184         case *DHCPProxyDetails:
 185                 return m, nil
 186         case *memclnt.ControlPingReply:
 187                 err = c.Stream.Close()
 188                 if err != nil {
 189                         return nil, err
 190                 }
 191                 return nil, io.EOF
 192         default:
 193                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 194         }
 195 }
 196
 197 func (c *serviceClient) DHCPProxySetVss(ctx context.Context, in *DHCPProxySetVss) (*DHCPProxySetVssReply, error) {
 198         out := new(DHCPProxySetVssReply)
 199         err := c.conn.Invoke(ctx, in, out)
 200         if err != nil {
 201                 return nil, err
 202         }
 203         return out, api.RetvalToVPPApiError(out.Retval)
 204 }
 205
 206 func (c *serviceClient) WantDHCP6PdReplyEvents(ctx context.Context, in *WantDHCP6PdReplyEvents) (*WantDHCP6PdReplyEventsReply, error) {
 207         out := new(WantDHCP6PdReplyEventsReply)
 208         err := c.conn.Invoke(ctx, in, out)
 209         if err != nil {
 210                 return nil, err
 211         }
 212         return out, api.RetvalToVPPApiError(out.Retval)
 213 }
 214
 215 func (c *serviceClient) WantDHCP6ReplyEvents(ctx context.Context, in *WantDHCP6ReplyEvents) (*WantDHCP6ReplyEventsReply, error) {
 216         out := new(WantDHCP6ReplyEventsReply)
 217         err := c.conn.Invoke(ctx, in, out)
 218         if err != nil {
 219                 return nil, err
 220         }
 221         return out, api.RetvalToVPPApiError(out.Retval)
 222 }