binapi/bfd/bfd_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package bfd
   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  bfd.
  15 type RPCService interface {
  16         BfdAuthDelKey(ctx context.Context, in *BfdAuthDelKey) (*BfdAuthDelKeyReply, error)
  17         BfdAuthKeysDump(ctx context.Context, in *BfdAuthKeysDump) (RPCService_BfdAuthKeysDumpClient, error)
  18         BfdAuthSetKey(ctx context.Context, in *BfdAuthSetKey) (*BfdAuthSetKeyReply, error)
  19         BfdUDPAdd(ctx context.Context, in *BfdUDPAdd) (*BfdUDPAddReply, error)
  20         BfdUDPAuthActivate(ctx context.Context, in *BfdUDPAuthActivate) (*BfdUDPAuthActivateReply, error)
  21         BfdUDPAuthDeactivate(ctx context.Context, in *BfdUDPAuthDeactivate) (*BfdUDPAuthDeactivateReply, error)
  22         BfdUDPDel(ctx context.Context, in *BfdUDPDel) (*BfdUDPDelReply, error)
  23         BfdUDPDelEchoSource(ctx context.Context, in *BfdUDPDelEchoSource) (*BfdUDPDelEchoSourceReply, error)
  24         BfdUDPGetEchoSource(ctx context.Context, in *BfdUDPGetEchoSource) (*BfdUDPGetEchoSourceReply, error)
  25         BfdUDPMod(ctx context.Context, in *BfdUDPMod) (*BfdUDPModReply, error)
  26         BfdUDPSessionDump(ctx context.Context, in *BfdUDPSessionDump) (RPCService_BfdUDPSessionDumpClient, error)
  27         BfdUDPSessionSetFlags(ctx context.Context, in *BfdUDPSessionSetFlags) (*BfdUDPSessionSetFlagsReply, error)
  28         BfdUDPSetEchoSource(ctx context.Context, in *BfdUDPSetEchoSource) (*BfdUDPSetEchoSourceReply, error)
  29         WantBfdEvents(ctx context.Context, in *WantBfdEvents) (*WantBfdEventsReply, error)
  30 }
  31
  32 type serviceClient struct {
  33         conn api.Connection
  34 }
  35
  36 func NewServiceClient(conn api.Connection) RPCService {
  37         return &serviceClient{conn}
  38 }
  39
  40 func (c *serviceClient) BfdAuthDelKey(ctx context.Context, in *BfdAuthDelKey) (*BfdAuthDelKeyReply, error) {
  41         out := new(BfdAuthDelKeyReply)
  42         err := c.conn.Invoke(ctx, in, out)
  43         if err != nil {
  44                 return nil, err
  45         }
  46         return out, nil
  47 }
  48
  49 func (c *serviceClient) BfdAuthKeysDump(ctx context.Context, in *BfdAuthKeysDump) (RPCService_BfdAuthKeysDumpClient, error) {
  50         stream, err := c.conn.NewStream(ctx)
  51         if err != nil {
  52                 return nil, err
  53         }
  54         x := &serviceClient_BfdAuthKeysDumpClient{stream}
  55         if err := x.Stream.SendMsg(in); err != nil {
  56                 return nil, err
  57         }
  58         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  59                 return nil, err
  60         }
  61         return x, nil
  62 }
  63
  64 type RPCService_BfdAuthKeysDumpClient interface {
  65         Recv() (*BfdAuthKeysDetails, error)
  66         api.Stream
  67 }
  68
  69 type serviceClient_BfdAuthKeysDumpClient struct {
  70         api.Stream
  71 }
  72
  73 func (c *serviceClient_BfdAuthKeysDumpClient) Recv() (*BfdAuthKeysDetails, error) {
  74         msg, err := c.Stream.RecvMsg()
  75         if err != nil {
  76                 return nil, err
  77         }
  78         switch m := msg.(type) {
  79         case *BfdAuthKeysDetails:
  80                 return m, nil
  81         case *vpe.ControlPingReply:
  82                 return nil, io.EOF
  83         default:
  84                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  85         }
  86 }
  87
  88 func (c *serviceClient) BfdAuthSetKey(ctx context.Context, in *BfdAuthSetKey) (*BfdAuthSetKeyReply, error) {
  89         out := new(BfdAuthSetKeyReply)
  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) BfdUDPAdd(ctx context.Context, in *BfdUDPAdd) (*BfdUDPAddReply, error) {
  98         out := new(BfdUDPAddReply)
  99         err := c.conn.Invoke(ctx, in, out)
 100         if err != nil {
 101                 return nil, err
 102         }
 103         return out, nil
 104 }
 105
 106 func (c *serviceClient) BfdUDPAuthActivate(ctx context.Context, in *BfdUDPAuthActivate) (*BfdUDPAuthActivateReply, error) {
 107         out := new(BfdUDPAuthActivateReply)
 108         err := c.conn.Invoke(ctx, in, out)
 109         if err != nil {
 110                 return nil, err
 111         }
 112         return out, nil
 113 }
 114
 115 func (c *serviceClient) BfdUDPAuthDeactivate(ctx context.Context, in *BfdUDPAuthDeactivate) (*BfdUDPAuthDeactivateReply, error) {
 116         out := new(BfdUDPAuthDeactivateReply)
 117         err := c.conn.Invoke(ctx, in, out)
 118         if err != nil {
 119                 return nil, err
 120         }
 121         return out, nil
 122 }
 123
 124 func (c *serviceClient) BfdUDPDel(ctx context.Context, in *BfdUDPDel) (*BfdUDPDelReply, error) {
 125         out := new(BfdUDPDelReply)
 126         err := c.conn.Invoke(ctx, in, out)
 127         if err != nil {
 128                 return nil, err
 129         }
 130         return out, nil
 131 }
 132
 133 func (c *serviceClient) BfdUDPDelEchoSource(ctx context.Context, in *BfdUDPDelEchoSource) (*BfdUDPDelEchoSourceReply, error) {
 134         out := new(BfdUDPDelEchoSourceReply)
 135         err := c.conn.Invoke(ctx, in, out)
 136         if err != nil {
 137                 return nil, err
 138         }
 139         return out, nil
 140 }
 141
 142 func (c *serviceClient) BfdUDPGetEchoSource(ctx context.Context, in *BfdUDPGetEchoSource) (*BfdUDPGetEchoSourceReply, error) {
 143         out := new(BfdUDPGetEchoSourceReply)
 144         err := c.conn.Invoke(ctx, in, out)
 145         if err != nil {
 146                 return nil, err
 147         }
 148         return out, nil
 149 }
 150
 151 func (c *serviceClient) BfdUDPMod(ctx context.Context, in *BfdUDPMod) (*BfdUDPModReply, error) {
 152         out := new(BfdUDPModReply)
 153         err := c.conn.Invoke(ctx, in, out)
 154         if err != nil {
 155                 return nil, err
 156         }
 157         return out, nil
 158 }
 159
 160 func (c *serviceClient) BfdUDPSessionDump(ctx context.Context, in *BfdUDPSessionDump) (RPCService_BfdUDPSessionDumpClient, error) {
 161         stream, err := c.conn.NewStream(ctx)
 162         if err != nil {
 163                 return nil, err
 164         }
 165         x := &serviceClient_BfdUDPSessionDumpClient{stream}
 166         if err := x.Stream.SendMsg(in); err != nil {
 167                 return nil, err
 168         }
 169         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 170                 return nil, err
 171         }
 172         return x, nil
 173 }
 174
 175 type RPCService_BfdUDPSessionDumpClient interface {
 176         Recv() (*BfdUDPSessionDetails, error)
 177         api.Stream
 178 }
 179
 180 type serviceClient_BfdUDPSessionDumpClient struct {
 181         api.Stream
 182 }
 183
 184 func (c *serviceClient_BfdUDPSessionDumpClient) Recv() (*BfdUDPSessionDetails, error) {
 185         msg, err := c.Stream.RecvMsg()
 186         if err != nil {
 187                 return nil, err
 188         }
 189         switch m := msg.(type) {
 190         case *BfdUDPSessionDetails:
 191                 return m, nil
 192         case *vpe.ControlPingReply:
 193                 return nil, io.EOF
 194         default:
 195                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 196         }
 197 }
 198
 199 func (c *serviceClient) BfdUDPSessionSetFlags(ctx context.Context, in *BfdUDPSessionSetFlags) (*BfdUDPSessionSetFlagsReply, error) {
 200         out := new(BfdUDPSessionSetFlagsReply)
 201         err := c.conn.Invoke(ctx, in, out)
 202         if err != nil {
 203                 return nil, err
 204         }
 205         return out, nil
 206 }
 207
 208 func (c *serviceClient) BfdUDPSetEchoSource(ctx context.Context, in *BfdUDPSetEchoSource) (*BfdUDPSetEchoSourceReply, error) {
 209         out := new(BfdUDPSetEchoSourceReply)
 210         err := c.conn.Invoke(ctx, in, out)
 211         if err != nil {
 212                 return nil, err
 213         }
 214         return out, nil
 215 }
 216
 217 func (c *serviceClient) WantBfdEvents(ctx context.Context, in *WantBfdEvents) (*WantBfdEventsReply, error) {
 218         out := new(WantBfdEventsReply)
 219         err := c.conn.Invoke(ctx, in, out)
 220         if err != nil {
 221                 return nil, err
 222         }
 223         return out, nil
 224 }