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 "go.fd.io/govpp/api"
  11         memclnt "go.fd.io/govpp/binapi/memclnt"
  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(&memclnt.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 *memclnt.ControlPingReply:
 132                 err = c.Stream.Close()
 133                 if err != nil {
 134                         return nil, err
 135                 }
 136                 return nil, io.EOF
 137         default:
 138                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 139         }
 140 }
 141
 142 func (c *serviceClient) Det44MapDump(ctx context.Context, in *Det44MapDump) (RPCService_Det44MapDumpClient, error) {
 143         stream, err := c.conn.NewStream(ctx)
 144         if err != nil {
 145                 return nil, err
 146         }
 147         x := &serviceClient_Det44MapDumpClient{stream}
 148         if err := x.Stream.SendMsg(in); err != nil {
 149                 return nil, err
 150         }
 151         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 152                 return nil, err
 153         }
 154         return x, nil
 155 }
 156
 157 type RPCService_Det44MapDumpClient interface {
 158         Recv() (*Det44MapDetails, error)
 159         api.Stream
 160 }
 161
 162 type serviceClient_Det44MapDumpClient struct {
 163         api.Stream
 164 }
 165
 166 func (c *serviceClient_Det44MapDumpClient) Recv() (*Det44MapDetails, error) {
 167         msg, err := c.Stream.RecvMsg()
 168         if err != nil {
 169                 return nil, err
 170         }
 171         switch m := msg.(type) {
 172         case *Det44MapDetails:
 173                 return m, nil
 174         case *memclnt.ControlPingReply:
 175                 err = c.Stream.Close()
 176                 if err != nil {
 177                         return nil, err
 178                 }
 179                 return nil, io.EOF
 180         default:
 181                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 182         }
 183 }
 184
 185 func (c *serviceClient) Det44PluginEnableDisable(ctx context.Context, in *Det44PluginEnableDisable) (*Det44PluginEnableDisableReply, error) {
 186         out := new(Det44PluginEnableDisableReply)
 187         err := c.conn.Invoke(ctx, in, out)
 188         if err != nil {
 189                 return nil, err
 190         }
 191         return out, api.RetvalToVPPApiError(out.Retval)
 192 }
 193
 194 func (c *serviceClient) Det44Reverse(ctx context.Context, in *Det44Reverse) (*Det44ReverseReply, error) {
 195         out := new(Det44ReverseReply)
 196         err := c.conn.Invoke(ctx, in, out)
 197         if err != nil {
 198                 return nil, err
 199         }
 200         return out, api.RetvalToVPPApiError(out.Retval)
 201 }
 202
 203 func (c *serviceClient) Det44SessionDump(ctx context.Context, in *Det44SessionDump) (RPCService_Det44SessionDumpClient, error) {
 204         stream, err := c.conn.NewStream(ctx)
 205         if err != nil {
 206                 return nil, err
 207         }
 208         x := &serviceClient_Det44SessionDumpClient{stream}
 209         if err := x.Stream.SendMsg(in); err != nil {
 210                 return nil, err
 211         }
 212         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 213                 return nil, err
 214         }
 215         return x, nil
 216 }
 217
 218 type RPCService_Det44SessionDumpClient interface {
 219         Recv() (*Det44SessionDetails, error)
 220         api.Stream
 221 }
 222
 223 type serviceClient_Det44SessionDumpClient struct {
 224         api.Stream
 225 }
 226
 227 func (c *serviceClient_Det44SessionDumpClient) Recv() (*Det44SessionDetails, error) {
 228         msg, err := c.Stream.RecvMsg()
 229         if err != nil {
 230                 return nil, err
 231         }
 232         switch m := msg.(type) {
 233         case *Det44SessionDetails:
 234                 return m, nil
 235         case *memclnt.ControlPingReply:
 236                 err = c.Stream.Close()
 237                 if err != nil {
 238                         return nil, err
 239                 }
 240                 return nil, io.EOF
 241         default:
 242                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 243         }
 244 }
 245
 246 func (c *serviceClient) Det44SetTimeouts(ctx context.Context, in *Det44SetTimeouts) (*Det44SetTimeoutsReply, error) {
 247         out := new(Det44SetTimeoutsReply)
 248         err := c.conn.Invoke(ctx, in, out)
 249         if err != nil {
 250                 return nil, err
 251         }
 252         return out, api.RetvalToVPPApiError(out.Retval)
 253 }
 254
 255 func (c *serviceClient) NatDetAddDelMap(ctx context.Context, in *NatDetAddDelMap) (*NatDetAddDelMapReply, error) {
 256         out := new(NatDetAddDelMapReply)
 257         err := c.conn.Invoke(ctx, in, out)
 258         if err != nil {
 259                 return nil, err
 260         }
 261         return out, api.RetvalToVPPApiError(out.Retval)
 262 }
 263
 264 func (c *serviceClient) NatDetCloseSessionIn(ctx context.Context, in *NatDetCloseSessionIn) (*NatDetCloseSessionInReply, error) {
 265         out := new(NatDetCloseSessionInReply)
 266         err := c.conn.Invoke(ctx, in, out)
 267         if err != nil {
 268                 return nil, err
 269         }
 270         return out, api.RetvalToVPPApiError(out.Retval)
 271 }
 272
 273 func (c *serviceClient) NatDetCloseSessionOut(ctx context.Context, in *NatDetCloseSessionOut) (*NatDetCloseSessionOutReply, error) {
 274         out := new(NatDetCloseSessionOutReply)
 275         err := c.conn.Invoke(ctx, in, out)
 276         if err != nil {
 277                 return nil, err
 278         }
 279         return out, api.RetvalToVPPApiError(out.Retval)
 280 }
 281
 282 func (c *serviceClient) NatDetForward(ctx context.Context, in *NatDetForward) (*NatDetForwardReply, error) {
 283         out := new(NatDetForwardReply)
 284         err := c.conn.Invoke(ctx, in, out)
 285         if err != nil {
 286                 return nil, err
 287         }
 288         return out, api.RetvalToVPPApiError(out.Retval)
 289 }
 290
 291 func (c *serviceClient) NatDetMapDump(ctx context.Context, in *NatDetMapDump) (RPCService_NatDetMapDumpClient, error) {
 292         stream, err := c.conn.NewStream(ctx)
 293         if err != nil {
 294                 return nil, err
 295         }
 296         x := &serviceClient_NatDetMapDumpClient{stream}
 297         if err := x.Stream.SendMsg(in); err != nil {
 298                 return nil, err
 299         }
 300         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 301                 return nil, err
 302         }
 303         return x, nil
 304 }
 305
 306 type RPCService_NatDetMapDumpClient interface {
 307         Recv() (*NatDetMapDetails, error)
 308         api.Stream
 309 }
 310
 311 type serviceClient_NatDetMapDumpClient struct {
 312         api.Stream
 313 }
 314
 315 func (c *serviceClient_NatDetMapDumpClient) Recv() (*NatDetMapDetails, error) {
 316         msg, err := c.Stream.RecvMsg()
 317         if err != nil {
 318                 return nil, err
 319         }
 320         switch m := msg.(type) {
 321         case *NatDetMapDetails:
 322                 return m, nil
 323         case *memclnt.ControlPingReply:
 324                 err = c.Stream.Close()
 325                 if err != nil {
 326                         return nil, err
 327                 }
 328                 return nil, io.EOF
 329         default:
 330                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 331         }
 332 }
 333
 334 func (c *serviceClient) NatDetReverse(ctx context.Context, in *NatDetReverse) (*NatDetReverseReply, error) {
 335         out := new(NatDetReverseReply)
 336         err := c.conn.Invoke(ctx, in, out)
 337         if err != nil {
 338                 return nil, err
 339         }
 340         return out, api.RetvalToVPPApiError(out.Retval)
 341 }
 342
 343 func (c *serviceClient) NatDetSessionDump(ctx context.Context, in *NatDetSessionDump) (RPCService_NatDetSessionDumpClient, error) {
 344         stream, err := c.conn.NewStream(ctx)
 345         if err != nil {
 346                 return nil, err
 347         }
 348         x := &serviceClient_NatDetSessionDumpClient{stream}
 349         if err := x.Stream.SendMsg(in); err != nil {
 350                 return nil, err
 351         }
 352         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 353                 return nil, err
 354         }
 355         return x, nil
 356 }
 357
 358 type RPCService_NatDetSessionDumpClient interface {
 359         Recv() (*NatDetSessionDetails, error)
 360         api.Stream
 361 }
 362
 363 type serviceClient_NatDetSessionDumpClient struct {
 364         api.Stream
 365 }
 366
 367 func (c *serviceClient_NatDetSessionDumpClient) Recv() (*NatDetSessionDetails, error) {
 368         msg, err := c.Stream.RecvMsg()
 369         if err != nil {
 370                 return nil, err
 371         }
 372         switch m := msg.(type) {
 373         case *NatDetSessionDetails:
 374                 return m, nil
 375         case *memclnt.ControlPingReply:
 376                 err = c.Stream.Close()
 377                 if err != nil {
 378                         return nil, err
 379                 }
 380                 return nil, io.EOF
 381         default:
 382                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 383         }
 384 }