binapi/det44/det44_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package det44
   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 det44.
  15 type RPCService interface {
  16         Det44AddDelMap(ctx context.Context, in *Det44AddDelMap) (*Det44AddDelMapReply, error)
  17         Det44CloseSessionIn(ctx context.Context, in *Det44CloseSessionIn) (*Det44CloseSessionInReply, error)
  18         Det44CloseSessionOut(ctx context.Context, in *Det44CloseSessionOut) (*Det44CloseSessionOutReply, error)
  19         Det44Forward(ctx context.Context, in *Det44Forward) (*Det44ForwardReply, error)
  20         Det44GetTimeouts(ctx context.Context, in *Det44GetTimeouts) (*Det44GetTimeoutsReply, error)
  21         Det44InterfaceAddDelFeature(ctx context.Context, in *Det44InterfaceAddDelFeature) (*Det44InterfaceAddDelFeatureReply, error)
  22         Det44InterfaceDump(ctx context.Context, in *Det44InterfaceDump) (RPCService_Det44InterfaceDumpClient, error)
  23         Det44MapDump(ctx context.Context, in *Det44MapDump) (RPCService_Det44MapDumpClient, error)
  24         Det44PluginEnableDisable(ctx context.Context, in *Det44PluginEnableDisable) (*Det44PluginEnableDisableReply, error)
  25         Det44Reverse(ctx context.Context, in *Det44Reverse) (*Det44ReverseReply, error)
  26         Det44SessionDump(ctx context.Context, in *Det44SessionDump) (RPCService_Det44SessionDumpClient, error)
  27         Det44SetTimeouts(ctx context.Context, in *Det44SetTimeouts) (*Det44SetTimeoutsReply, error)
  28         NatDetAddDelMap(ctx context.Context, in *NatDetAddDelMap) (*NatDetAddDelMapReply, error)
  29         NatDetCloseSessionIn(ctx context.Context, in *NatDetCloseSessionIn) (*NatDetCloseSessionInReply, error)
  30         NatDetCloseSessionOut(ctx context.Context, in *NatDetCloseSessionOut) (*NatDetCloseSessionOutReply, error)
  31         NatDetForward(ctx context.Context, in *NatDetForward) (*NatDetForwardReply, error)
  32         NatDetMapDump(ctx context.Context, in *NatDetMapDump) (RPCService_NatDetMapDumpClient, error)
  33         NatDetReverse(ctx context.Context, in *NatDetReverse) (*NatDetReverseReply, error)
  34         NatDetSessionDump(ctx context.Context, in *NatDetSessionDump) (RPCService_NatDetSessionDumpClient, error)
  35 }
  36
  37 type serviceClient struct {
  38         conn api.Connection
  39 }
  40
  41 func NewServiceClient(conn api.Connection) RPCService {
  42         return &serviceClient{conn}
  43 }
  44
  45 func (c *serviceClient) Det44AddDelMap(ctx context.Context, in *Det44AddDelMap) (*Det44AddDelMapReply, error) {
  46         out := new(Det44AddDelMapReply)
  47         err := c.conn.Invoke(ctx, in, out)
  48         if err != nil {
  49                 return nil, err
  50         }
  51         return out, api.RetvalToVPPApiError(out.Retval)
  52 }
  53
  54 func (c *serviceClient) Det44CloseSessionIn(ctx context.Context, in *Det44CloseSessionIn) (*Det44CloseSessionInReply, error) {
  55         out := new(Det44CloseSessionInReply)
  56         err := c.conn.Invoke(ctx, in, out)
  57         if err != nil {
  58                 return nil, err
  59         }
  60         return out, api.RetvalToVPPApiError(out.Retval)
  61 }
  62
  63 func (c *serviceClient) Det44CloseSessionOut(ctx context.Context, in *Det44CloseSessionOut) (*Det44CloseSessionOutReply, error) {
  64         out := new(Det44CloseSessionOutReply)
  65         err := c.conn.Invoke(ctx, in, out)
  66         if err != nil {
  67                 return nil, err
  68         }
  69         return out, api.RetvalToVPPApiError(out.Retval)
  70 }
  71
  72 func (c *serviceClient) Det44Forward(ctx context.Context, in *Det44Forward) (*Det44ForwardReply, error) {
  73         out := new(Det44ForwardReply)
  74         err := c.conn.Invoke(ctx, in, out)
  75         if err != nil {
  76                 return nil, err
  77         }
  78         return out, api.RetvalToVPPApiError(out.Retval)
  79 }
  80
  81 func (c *serviceClient) Det44GetTimeouts(ctx context.Context, in *Det44GetTimeouts) (*Det44GetTimeoutsReply, error) {
  82         out := new(Det44GetTimeoutsReply)
  83         err := c.conn.Invoke(ctx, in, out)
  84         if err != nil {
  85                 return nil, err
  86         }
  87         return out, api.RetvalToVPPApiError(out.Retval)
  88 }
  89
  90 func (c *serviceClient) Det44InterfaceAddDelFeature(ctx context.Context, in *Det44InterfaceAddDelFeature) (*Det44InterfaceAddDelFeatureReply, error) {
  91         out := new(Det44InterfaceAddDelFeatureReply)
  92         err := c.conn.Invoke(ctx, in, out)
  93         if err != nil {
  94                 return nil, err
  95         }
  96         return out, api.RetvalToVPPApiError(out.Retval)
  97 }
  98
  99 func (c *serviceClient) Det44InterfaceDump(ctx context.Context, in *Det44InterfaceDump) (RPCService_Det44InterfaceDumpClient, error) {
 100         stream, err := c.conn.NewStream(ctx)
 101         if err != nil {
 102                 return nil, err
 103         }
 104         x := &serviceClient_Det44InterfaceDumpClient{stream}
 105         if err := x.Stream.SendMsg(in); err != nil {
 106                 return nil, err
 107         }
 108         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 109                 return nil, err
 110         }
 111         return x, nil
 112 }
 113
 114 type RPCService_Det44InterfaceDumpClient interface {
 115         Recv() (*Det44InterfaceDetails, error)
 116         api.Stream
 117 }
 118
 119 type serviceClient_Det44InterfaceDumpClient struct {
 120         api.Stream
 121 }
 122
 123 func (c *serviceClient_Det44InterfaceDumpClient) Recv() (*Det44InterfaceDetails, error) {
 124         msg, err := c.Stream.RecvMsg()
 125         if err != nil {
 126                 return nil, err
 127         }
 128         switch m := msg.(type) {
 129         case *Det44InterfaceDetails:
 130                 return m, nil
 131         case *vpe.ControlPingReply:
 132                 return nil, io.EOF
 133         default:
 134                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 135         }
 136 }
 137
 138 func (c *serviceClient) Det44MapDump(ctx context.Context, in *Det44MapDump) (RPCService_Det44MapDumpClient, error) {
 139         stream, err := c.conn.NewStream(ctx)
 140         if err != nil {
 141                 return nil, err
 142         }
 143         x := &serviceClient_Det44MapDumpClient{stream}
 144         if err := x.Stream.SendMsg(in); err != nil {
 145                 return nil, err
 146         }
 147         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 148                 return nil, err
 149         }
 150         return x, nil
 151 }
 152
 153 type RPCService_Det44MapDumpClient interface {
 154         Recv() (*Det44MapDetails, error)
 155         api.Stream
 156 }
 157
 158 type serviceClient_Det44MapDumpClient struct {
 159         api.Stream
 160 }
 161
 162 func (c *serviceClient_Det44MapDumpClient) Recv() (*Det44MapDetails, error) {
 163         msg, err := c.Stream.RecvMsg()
 164         if err != nil {
 165                 return nil, err
 166         }
 167         switch m := msg.(type) {
 168         case *Det44MapDetails:
 169                 return m, nil
 170         case *vpe.ControlPingReply:
 171                 return nil, io.EOF
 172         default:
 173                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 174         }
 175 }
 176
 177 func (c *serviceClient) Det44PluginEnableDisable(ctx context.Context, in *Det44PluginEnableDisable) (*Det44PluginEnableDisableReply, error) {
 178         out := new(Det44PluginEnableDisableReply)
 179         err := c.conn.Invoke(ctx, in, out)
 180         if err != nil {
 181                 return nil, err
 182         }
 183         return out, api.RetvalToVPPApiError(out.Retval)
 184 }
 185
 186 func (c *serviceClient) Det44Reverse(ctx context.Context, in *Det44Reverse) (*Det44ReverseReply, error) {
 187         out := new(Det44ReverseReply)
 188         err := c.conn.Invoke(ctx, in, out)
 189         if err != nil {
 190                 return nil, err
 191         }
 192         return out, api.RetvalToVPPApiError(out.Retval)
 193 }
 194
 195 func (c *serviceClient) Det44SessionDump(ctx context.Context, in *Det44SessionDump) (RPCService_Det44SessionDumpClient, error) {
 196         stream, err := c.conn.NewStream(ctx)
 197         if err != nil {
 198                 return nil, err
 199         }
 200         x := &serviceClient_Det44SessionDumpClient{stream}
 201         if err := x.Stream.SendMsg(in); err != nil {
 202                 return nil, err
 203         }
 204         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 205                 return nil, err
 206         }
 207         return x, nil
 208 }
 209
 210 type RPCService_Det44SessionDumpClient interface {
 211         Recv() (*Det44SessionDetails, error)
 212         api.Stream
 213 }
 214
 215 type serviceClient_Det44SessionDumpClient struct {
 216         api.Stream
 217 }
 218
 219 func (c *serviceClient_Det44SessionDumpClient) Recv() (*Det44SessionDetails, error) {
 220         msg, err := c.Stream.RecvMsg()
 221         if err != nil {
 222                 return nil, err
 223         }
 224         switch m := msg.(type) {
 225         case *Det44SessionDetails:
 226                 return m, nil
 227         case *vpe.ControlPingReply:
 228                 return nil, io.EOF
 229         default:
 230                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 231         }
 232 }
 233
 234 func (c *serviceClient) Det44SetTimeouts(ctx context.Context, in *Det44SetTimeouts) (*Det44SetTimeoutsReply, error) {
 235         out := new(Det44SetTimeoutsReply)
 236         err := c.conn.Invoke(ctx, in, out)
 237         if err != nil {
 238                 return nil, err
 239         }
 240         return out, api.RetvalToVPPApiError(out.Retval)
 241 }
 242
 243 func (c *serviceClient) NatDetAddDelMap(ctx context.Context, in *NatDetAddDelMap) (*NatDetAddDelMapReply, error) {
 244         out := new(NatDetAddDelMapReply)
 245         err := c.conn.Invoke(ctx, in, out)
 246         if err != nil {
 247                 return nil, err
 248         }
 249         return out, api.RetvalToVPPApiError(out.Retval)
 250 }
 251
 252 func (c *serviceClient) NatDetCloseSessionIn(ctx context.Context, in *NatDetCloseSessionIn) (*NatDetCloseSessionInReply, error) {
 253         out := new(NatDetCloseSessionInReply)
 254         err := c.conn.Invoke(ctx, in, out)
 255         if err != nil {
 256                 return nil, err
 257         }
 258         return out, api.RetvalToVPPApiError(out.Retval)
 259 }
 260
 261 func (c *serviceClient) NatDetCloseSessionOut(ctx context.Context, in *NatDetCloseSessionOut) (*NatDetCloseSessionOutReply, error) {
 262         out := new(NatDetCloseSessionOutReply)
 263         err := c.conn.Invoke(ctx, in, out)
 264         if err != nil {
 265                 return nil, err
 266         }
 267         return out, api.RetvalToVPPApiError(out.Retval)
 268 }
 269
 270 func (c *serviceClient) NatDetForward(ctx context.Context, in *NatDetForward) (*NatDetForwardReply, error) {
 271         out := new(NatDetForwardReply)
 272         err := c.conn.Invoke(ctx, in, out)
 273         if err != nil {
 274                 return nil, err
 275         }
 276         return out, api.RetvalToVPPApiError(out.Retval)
 277 }
 278
 279 func (c *serviceClient) NatDetMapDump(ctx context.Context, in *NatDetMapDump) (RPCService_NatDetMapDumpClient, error) {
 280         stream, err := c.conn.NewStream(ctx)
 281         if err != nil {
 282                 return nil, err
 283         }
 284         x := &serviceClient_NatDetMapDumpClient{stream}
 285         if err := x.Stream.SendMsg(in); err != nil {
 286                 return nil, err
 287         }
 288         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 289                 return nil, err
 290         }
 291         return x, nil
 292 }
 293
 294 type RPCService_NatDetMapDumpClient interface {
 295         Recv() (*NatDetMapDetails, error)
 296         api.Stream
 297 }
 298
 299 type serviceClient_NatDetMapDumpClient struct {
 300         api.Stream
 301 }
 302
 303 func (c *serviceClient_NatDetMapDumpClient) Recv() (*NatDetMapDetails, error) {
 304         msg, err := c.Stream.RecvMsg()
 305         if err != nil {
 306                 return nil, err
 307         }
 308         switch m := msg.(type) {
 309         case *NatDetMapDetails:
 310                 return m, nil
 311         case *vpe.ControlPingReply:
 312                 return nil, io.EOF
 313         default:
 314                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 315         }
 316 }
 317
 318 func (c *serviceClient) NatDetReverse(ctx context.Context, in *NatDetReverse) (*NatDetReverseReply, error) {
 319         out := new(NatDetReverseReply)
 320         err := c.conn.Invoke(ctx, in, out)
 321         if err != nil {
 322                 return nil, err
 323         }
 324         return out, api.RetvalToVPPApiError(out.Retval)
 325 }
 326
 327 func (c *serviceClient) NatDetSessionDump(ctx context.Context, in *NatDetSessionDump) (RPCService_NatDetSessionDumpClient, error) {
 328         stream, err := c.conn.NewStream(ctx)
 329         if err != nil {
 330                 return nil, err
 331         }
 332         x := &serviceClient_NatDetSessionDumpClient{stream}
 333         if err := x.Stream.SendMsg(in); err != nil {
 334                 return nil, err
 335         }
 336         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 337                 return nil, err
 338         }
 339         return x, nil
 340 }
 341
 342 type RPCService_NatDetSessionDumpClient interface {
 343         Recv() (*NatDetSessionDetails, error)
 344         api.Stream
 345 }
 346
 347 type serviceClient_NatDetSessionDumpClient struct {
 348         api.Stream
 349 }
 350
 351 func (c *serviceClient_NatDetSessionDumpClient) Recv() (*NatDetSessionDetails, error) {
 352         msg, err := c.Stream.RecvMsg()
 353         if err != nil {
 354                 return nil, err
 355         }
 356         switch m := msg.(type) {
 357         case *NatDetSessionDetails:
 358                 return m, nil
 359         case *vpe.ControlPingReply:
 360                 return nil, io.EOF
 361         default:
 362                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 363         }
 364 }