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