1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
8 api "git.fd.io/govpp.git/api"
9 vpe "git.fd.io/govpp.git/internal/testbinapi/binapi2001/vpe"
13 // RPCService defines RPC service bier.
14 type RPCService interface {
15 BierDispEntryAddDel(ctx context.Context, in *BierDispEntryAddDel) (*BierDispEntryAddDelReply, error)
16 BierDispEntryDump(ctx context.Context, in *BierDispEntryDump) (RPCService_BierDispEntryDumpClient, error)
17 BierDispTableAddDel(ctx context.Context, in *BierDispTableAddDel) (*BierDispTableAddDelReply, error)
18 BierDispTableDump(ctx context.Context, in *BierDispTableDump) (RPCService_BierDispTableDumpClient, error)
19 BierImpAdd(ctx context.Context, in *BierImpAdd) (*BierImpAddReply, error)
20 BierImpDel(ctx context.Context, in *BierImpDel) (*BierImpDelReply, error)
21 BierImpDump(ctx context.Context, in *BierImpDump) (RPCService_BierImpDumpClient, error)
22 BierRouteAddDel(ctx context.Context, in *BierRouteAddDel) (*BierRouteAddDelReply, error)
23 BierRouteDump(ctx context.Context, in *BierRouteDump) (RPCService_BierRouteDumpClient, error)
24 BierTableAddDel(ctx context.Context, in *BierTableAddDel) (*BierTableAddDelReply, error)
25 BierTableDump(ctx context.Context, in *BierTableDump) (RPCService_BierTableDumpClient, error)
28 type serviceClient struct {
32 func NewServiceClient(conn api.Connection) RPCService {
33 return &serviceClient{conn}
36 func (c *serviceClient) BierDispEntryAddDel(ctx context.Context, in *BierDispEntryAddDel) (*BierDispEntryAddDelReply, error) {
37 out := new(BierDispEntryAddDelReply)
38 err := c.conn.Invoke(ctx, in, out)
45 func (c *serviceClient) BierDispEntryDump(ctx context.Context, in *BierDispEntryDump) (RPCService_BierDispEntryDumpClient, error) {
46 stream, err := c.conn.NewStream(ctx)
50 x := &serviceClient_BierDispEntryDumpClient{stream}
51 if err := x.Stream.SendMsg(in); err != nil {
54 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
60 type RPCService_BierDispEntryDumpClient interface {
61 Recv() (*BierDispEntryDetails, error)
65 type serviceClient_BierDispEntryDumpClient struct {
69 func (c *serviceClient_BierDispEntryDumpClient) Recv() (*BierDispEntryDetails, error) {
70 msg, err := c.Stream.RecvMsg()
74 switch m := msg.(type) {
75 case *BierDispEntryDetails:
77 case *vpe.ControlPingReply:
80 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
84 func (c *serviceClient) BierDispTableAddDel(ctx context.Context, in *BierDispTableAddDel) (*BierDispTableAddDelReply, error) {
85 out := new(BierDispTableAddDelReply)
86 err := c.conn.Invoke(ctx, in, out)
93 func (c *serviceClient) BierDispTableDump(ctx context.Context, in *BierDispTableDump) (RPCService_BierDispTableDumpClient, error) {
94 stream, err := c.conn.NewStream(ctx)
98 x := &serviceClient_BierDispTableDumpClient{stream}
99 if err := x.Stream.SendMsg(in); err != nil {
102 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
108 type RPCService_BierDispTableDumpClient interface {
109 Recv() (*BierDispTableDetails, error)
113 type serviceClient_BierDispTableDumpClient struct {
117 func (c *serviceClient_BierDispTableDumpClient) Recv() (*BierDispTableDetails, error) {
118 msg, err := c.Stream.RecvMsg()
122 switch m := msg.(type) {
123 case *BierDispTableDetails:
125 case *vpe.ControlPingReply:
128 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
132 func (c *serviceClient) BierImpAdd(ctx context.Context, in *BierImpAdd) (*BierImpAddReply, error) {
133 out := new(BierImpAddReply)
134 err := c.conn.Invoke(ctx, in, out)
141 func (c *serviceClient) BierImpDel(ctx context.Context, in *BierImpDel) (*BierImpDelReply, error) {
142 out := new(BierImpDelReply)
143 err := c.conn.Invoke(ctx, in, out)
150 func (c *serviceClient) BierImpDump(ctx context.Context, in *BierImpDump) (RPCService_BierImpDumpClient, error) {
151 stream, err := c.conn.NewStream(ctx)
155 x := &serviceClient_BierImpDumpClient{stream}
156 if err := x.Stream.SendMsg(in); err != nil {
159 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
165 type RPCService_BierImpDumpClient interface {
166 Recv() (*BierImpDetails, error)
170 type serviceClient_BierImpDumpClient struct {
174 func (c *serviceClient_BierImpDumpClient) Recv() (*BierImpDetails, error) {
175 msg, err := c.Stream.RecvMsg()
179 switch m := msg.(type) {
180 case *BierImpDetails:
182 case *vpe.ControlPingReply:
185 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
189 func (c *serviceClient) BierRouteAddDel(ctx context.Context, in *BierRouteAddDel) (*BierRouteAddDelReply, error) {
190 out := new(BierRouteAddDelReply)
191 err := c.conn.Invoke(ctx, in, out)
198 func (c *serviceClient) BierRouteDump(ctx context.Context, in *BierRouteDump) (RPCService_BierRouteDumpClient, error) {
199 stream, err := c.conn.NewStream(ctx)
203 x := &serviceClient_BierRouteDumpClient{stream}
204 if err := x.Stream.SendMsg(in); err != nil {
207 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
213 type RPCService_BierRouteDumpClient interface {
214 Recv() (*BierRouteDetails, error)
218 type serviceClient_BierRouteDumpClient struct {
222 func (c *serviceClient_BierRouteDumpClient) Recv() (*BierRouteDetails, error) {
223 msg, err := c.Stream.RecvMsg()
227 switch m := msg.(type) {
228 case *BierRouteDetails:
230 case *vpe.ControlPingReply:
233 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
237 func (c *serviceClient) BierTableAddDel(ctx context.Context, in *BierTableAddDel) (*BierTableAddDelReply, error) {
238 out := new(BierTableAddDelReply)
239 err := c.conn.Invoke(ctx, in, out)
246 func (c *serviceClient) BierTableDump(ctx context.Context, in *BierTableDump) (RPCService_BierTableDumpClient, error) {
247 stream, err := c.conn.NewStream(ctx)
251 x := &serviceClient_BierTableDumpClient{stream}
252 if err := x.Stream.SendMsg(in); err != nil {
255 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
261 type RPCService_BierTableDumpClient interface {
262 Recv() (*BierTableDetails, error)
266 type serviceClient_BierTableDumpClient struct {
270 func (c *serviceClient_BierTableDumpClient) Recv() (*BierTableDetails, error) {
271 msg, err := c.Stream.RecvMsg()
275 switch m := msg.(type) {
276 case *BierTableDetails:
278 case *vpe.ControlPingReply:
281 return nil, fmt.Errorf("unexpected message: %T %v", m, m)