internal/testbinapi/binapi2001/abf/abf_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package abf
   4
   5 import (
   6         "context"
   7         "fmt"
   8         api "git.fd.io/govpp.git/api"
   9         vpe "git.fd.io/govpp.git/internal/testbinapi/binapi2001/vpe"
  10         "io"
  11 )
  12
  13 // RPCService defines RPC service  abf.
  14 type RPCService interface {
  15         AbfItfAttachAddDel(ctx context.Context, in *AbfItfAttachAddDel) (*AbfItfAttachAddDelReply, error)
  16         AbfItfAttachDump(ctx context.Context, in *AbfItfAttachDump) (RPCService_AbfItfAttachDumpClient, error)
  17         AbfPluginGetVersion(ctx context.Context, in *AbfPluginGetVersion) (*AbfPluginGetVersionReply, error)
  18         AbfPolicyAddDel(ctx context.Context, in *AbfPolicyAddDel) (*AbfPolicyAddDelReply, error)
  19         AbfPolicyDump(ctx context.Context, in *AbfPolicyDump) (RPCService_AbfPolicyDumpClient, error)
  20 }
  21
  22 type serviceClient struct {
  23         conn api.Connection
  24 }
  25
  26 func NewServiceClient(conn api.Connection) RPCService {
  27         return &serviceClient{conn}
  28 }
  29
  30 func (c *serviceClient) AbfItfAttachAddDel(ctx context.Context, in *AbfItfAttachAddDel) (*AbfItfAttachAddDelReply, error) {
  31         out := new(AbfItfAttachAddDelReply)
  32         err := c.conn.Invoke(ctx, in, out)
  33         if err != nil {
  34                 return nil, err
  35         }
  36         return out, nil
  37 }
  38
  39 func (c *serviceClient) AbfItfAttachDump(ctx context.Context, in *AbfItfAttachDump) (RPCService_AbfItfAttachDumpClient, error) {
  40         stream, err := c.conn.NewStream(ctx)
  41         if err != nil {
  42                 return nil, err
  43         }
  44         x := &serviceClient_AbfItfAttachDumpClient{stream}
  45         if err := x.Stream.SendMsg(in); err != nil {
  46                 return nil, err
  47         }
  48         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  49                 return nil, err
  50         }
  51         return x, nil
  52 }
  53
  54 type RPCService_AbfItfAttachDumpClient interface {
  55         Recv() (*AbfItfAttachDetails, error)
  56         api.Stream
  57 }
  58
  59 type serviceClient_AbfItfAttachDumpClient struct {
  60         api.Stream
  61 }
  62
  63 func (c *serviceClient_AbfItfAttachDumpClient) Recv() (*AbfItfAttachDetails, error) {
  64         msg, err := c.Stream.RecvMsg()
  65         if err != nil {
  66                 return nil, err
  67         }
  68         switch m := msg.(type) {
  69         case *AbfItfAttachDetails:
  70                 return m, nil
  71         case *vpe.ControlPingReply:
  72                 return nil, io.EOF
  73         default:
  74                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  75         }
  76 }
  77
  78 func (c *serviceClient) AbfPluginGetVersion(ctx context.Context, in *AbfPluginGetVersion) (*AbfPluginGetVersionReply, error) {
  79         out := new(AbfPluginGetVersionReply)
  80         err := c.conn.Invoke(ctx, in, out)
  81         if err != nil {
  82                 return nil, err
  83         }
  84         return out, nil
  85 }
  86
  87 func (c *serviceClient) AbfPolicyAddDel(ctx context.Context, in *AbfPolicyAddDel) (*AbfPolicyAddDelReply, error) {
  88         out := new(AbfPolicyAddDelReply)
  89         err := c.conn.Invoke(ctx, in, out)
  90         if err != nil {
  91                 return nil, err
  92         }
  93         return out, nil
  94 }
  95
  96 func (c *serviceClient) AbfPolicyDump(ctx context.Context, in *AbfPolicyDump) (RPCService_AbfPolicyDumpClient, error) {
  97         stream, err := c.conn.NewStream(ctx)
  98         if err != nil {
  99                 return nil, err
 100         }
 101         x := &serviceClient_AbfPolicyDumpClient{stream}
 102         if err := x.Stream.SendMsg(in); err != nil {
 103                 return nil, err
 104         }
 105         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 106                 return nil, err
 107         }
 108         return x, nil
 109 }
 110
 111 type RPCService_AbfPolicyDumpClient interface {
 112         Recv() (*AbfPolicyDetails, error)
 113         api.Stream
 114 }
 115
 116 type serviceClient_AbfPolicyDumpClient struct {
 117         api.Stream
 118 }
 119
 120 func (c *serviceClient_AbfPolicyDumpClient) Recv() (*AbfPolicyDetails, error) {
 121         msg, err := c.Stream.RecvMsg()
 122         if err != nil {
 123                 return nil, err
 124         }
 125         switch m := msg.(type) {
 126         case *AbfPolicyDetails:
 127                 return m, nil
 128         case *vpe.ControlPingReply:
 129                 return nil, io.EOF
 130         default:
 131                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 132         }
 133 }