1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "go.fd.io/govpp/api"
11 memclnt "go.fd.io/govpp/binapi/memclnt"
14 // RPCService defines RPC service udp.
15 type RPCService interface {
16 UDPDecapAddDel(ctx context.Context, in *UDPDecapAddDel) (*UDPDecapAddDelReply, error)
17 UDPEncapAdd(ctx context.Context, in *UDPEncapAdd) (*UDPEncapAddReply, error)
18 UDPEncapDel(ctx context.Context, in *UDPEncapDel) (*UDPEncapDelReply, error)
19 UDPEncapDump(ctx context.Context, in *UDPEncapDump) (RPCService_UDPEncapDumpClient, error)
22 type serviceClient struct {
26 func NewServiceClient(conn api.Connection) RPCService {
27 return &serviceClient{conn}
30 func (c *serviceClient) UDPDecapAddDel(ctx context.Context, in *UDPDecapAddDel) (*UDPDecapAddDelReply, error) {
31 out := new(UDPDecapAddDelReply)
32 err := c.conn.Invoke(ctx, in, out)
36 return out, api.RetvalToVPPApiError(out.Retval)
39 func (c *serviceClient) UDPEncapAdd(ctx context.Context, in *UDPEncapAdd) (*UDPEncapAddReply, error) {
40 out := new(UDPEncapAddReply)
41 err := c.conn.Invoke(ctx, in, out)
45 return out, api.RetvalToVPPApiError(out.Retval)
48 func (c *serviceClient) UDPEncapDel(ctx context.Context, in *UDPEncapDel) (*UDPEncapDelReply, error) {
49 out := new(UDPEncapDelReply)
50 err := c.conn.Invoke(ctx, in, out)
54 return out, api.RetvalToVPPApiError(out.Retval)
57 func (c *serviceClient) UDPEncapDump(ctx context.Context, in *UDPEncapDump) (RPCService_UDPEncapDumpClient, error) {
58 stream, err := c.conn.NewStream(ctx)
62 x := &serviceClient_UDPEncapDumpClient{stream}
63 if err := x.Stream.SendMsg(in); err != nil {
66 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
72 type RPCService_UDPEncapDumpClient interface {
73 Recv() (*UDPEncapDetails, error)
77 type serviceClient_UDPEncapDumpClient struct {
81 func (c *serviceClient_UDPEncapDumpClient) Recv() (*UDPEncapDetails, error) {
82 msg, err := c.Stream.RecvMsg()
86 switch m := msg.(type) {
87 case *UDPEncapDetails:
89 case *memclnt.ControlPingReply:
90 err = c.Stream.Close()
96 return nil, fmt.Errorf("unexpected message: %T %v", m, m)