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