binapi/graph/graph_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package graph
   4
   5 import (
   6         "context"
   7         "fmt"
   8         "io"
   9
  10         api "go.fd.io/govpp/api"
  11 )
  12
  13 // RPCService defines RPC service graph.
  14 type RPCService interface {
  15         GraphNodeGet(ctx context.Context, in *GraphNodeGet) (RPCService_GraphNodeGetClient, error)
  16 }
  17
  18 type serviceClient struct {
  19         conn api.Connection
  20 }
  21
  22 func NewServiceClient(conn api.Connection) RPCService {
  23         return &serviceClient{conn}
  24 }
  25
  26 func (c *serviceClient) GraphNodeGet(ctx context.Context, in *GraphNodeGet) (RPCService_GraphNodeGetClient, error) {
  27         stream, err := c.conn.NewStream(ctx)
  28         if err != nil {
  29                 return nil, err
  30         }
  31         x := &serviceClient_GraphNodeGetClient{stream}
  32         if err := x.Stream.SendMsg(in); err != nil {
  33                 return nil, err
  34         }
  35         return x, nil
  36 }
  37
  38 type RPCService_GraphNodeGetClient interface {
  39         Recv() (*GraphNodeDetails, error)
  40         api.Stream
  41 }
  42
  43 type serviceClient_GraphNodeGetClient struct {
  44         api.Stream
  45 }
  46
  47 func (c *serviceClient_GraphNodeGetClient) Recv() (*GraphNodeDetails, error) {
  48         msg, err := c.Stream.RecvMsg()
  49         if err != nil {
  50                 return nil, err
  51         }
  52         switch m := msg.(type) {
  53         case *GraphNodeDetails:
  54                 return m, nil
  55         case *GraphNodeGetReply:
  56                 err = c.Stream.Close()
  57                 if err != nil {
  58                         return nil, err
  59                 }
  60                 return nil, io.EOF
  61         default:
  62                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  63         }
  64 }