internal/testbinapi/binapi2001/sr/sr_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package sr
   4
   5 import (
   6         "context"
   7         "io"
   8
   9         api "git.fd.io/govpp.git/api"
  10 )
  11
  12 // RPCService represents RPC service API for sr module.
  13 type RPCService interface {
  14         DumpSrLocalsids(ctx context.Context, in *SrLocalsidsDump) (RPCService_DumpSrLocalsidsClient, error)
  15         DumpSrPolicies(ctx context.Context, in *SrPoliciesDump) (RPCService_DumpSrPoliciesClient, error)
  16         DumpSrSteeringPol(ctx context.Context, in *SrSteeringPolDump) (RPCService_DumpSrSteeringPolClient, error)
  17         SrLocalsidAddDel(ctx context.Context, in *SrLocalsidAddDel) (*SrLocalsidAddDelReply, error)
  18         SrPolicyAdd(ctx context.Context, in *SrPolicyAdd) (*SrPolicyAddReply, error)
  19         SrPolicyDel(ctx context.Context, in *SrPolicyDel) (*SrPolicyDelReply, error)
  20         SrPolicyMod(ctx context.Context, in *SrPolicyMod) (*SrPolicyModReply, error)
  21         SrSetEncapHopLimit(ctx context.Context, in *SrSetEncapHopLimit) (*SrSetEncapHopLimitReply, error)
  22         SrSetEncapSource(ctx context.Context, in *SrSetEncapSource) (*SrSetEncapSourceReply, error)
  23         SrSteeringAddDel(ctx context.Context, in *SrSteeringAddDel) (*SrSteeringAddDelReply, error)
  24 }
  25
  26 type serviceClient struct {
  27         ch api.Channel
  28 }
  29
  30 func NewServiceClient(ch api.Channel) RPCService {
  31         return &serviceClient{ch}
  32 }
  33
  34 func (c *serviceClient) DumpSrLocalsids(ctx context.Context, in *SrLocalsidsDump) (RPCService_DumpSrLocalsidsClient, error) {
  35         stream := c.ch.SendMultiRequest(in)
  36         x := &serviceClient_DumpSrLocalsidsClient{stream}
  37         return x, nil
  38 }
  39
  40 type RPCService_DumpSrLocalsidsClient interface {
  41         Recv() (*SrLocalsidsDetails, error)
  42 }
  43
  44 type serviceClient_DumpSrLocalsidsClient struct {
  45         api.MultiRequestCtx
  46 }
  47
  48 func (c *serviceClient_DumpSrLocalsidsClient) Recv() (*SrLocalsidsDetails, error) {
  49         m := new(SrLocalsidsDetails)
  50         stop, err := c.MultiRequestCtx.ReceiveReply(m)
  51         if err != nil {
  52                 return nil, err
  53         }
  54         if stop {
  55                 return nil, io.EOF
  56         }
  57         return m, nil
  58 }
  59
  60 func (c *serviceClient) DumpSrPolicies(ctx context.Context, in *SrPoliciesDump) (RPCService_DumpSrPoliciesClient, error) {
  61         stream := c.ch.SendMultiRequest(in)
  62         x := &serviceClient_DumpSrPoliciesClient{stream}
  63         return x, nil
  64 }
  65
  66 type RPCService_DumpSrPoliciesClient interface {
  67         Recv() (*SrPoliciesDetails, error)
  68 }
  69
  70 type serviceClient_DumpSrPoliciesClient struct {
  71         api.MultiRequestCtx
  72 }
  73
  74 func (c *serviceClient_DumpSrPoliciesClient) Recv() (*SrPoliciesDetails, error) {
  75         m := new(SrPoliciesDetails)
  76         stop, err := c.MultiRequestCtx.ReceiveReply(m)
  77         if err != nil {
  78                 return nil, err
  79         }
  80         if stop {
  81                 return nil, io.EOF
  82         }
  83         return m, nil
  84 }
  85
  86 func (c *serviceClient) DumpSrSteeringPol(ctx context.Context, in *SrSteeringPolDump) (RPCService_DumpSrSteeringPolClient, error) {
  87         stream := c.ch.SendMultiRequest(in)
  88         x := &serviceClient_DumpSrSteeringPolClient{stream}
  89         return x, nil
  90 }
  91
  92 type RPCService_DumpSrSteeringPolClient interface {
  93         Recv() (*SrSteeringPolDetails, error)
  94 }
  95
  96 type serviceClient_DumpSrSteeringPolClient struct {
  97         api.MultiRequestCtx
  98 }
  99
 100 func (c *serviceClient_DumpSrSteeringPolClient) Recv() (*SrSteeringPolDetails, error) {
 101         m := new(SrSteeringPolDetails)
 102         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 103         if err != nil {
 104                 return nil, err
 105         }
 106         if stop {
 107                 return nil, io.EOF
 108         }
 109         return m, nil
 110 }
 111
 112 func (c *serviceClient) SrLocalsidAddDel(ctx context.Context, in *SrLocalsidAddDel) (*SrLocalsidAddDelReply, error) {
 113         out := new(SrLocalsidAddDelReply)
 114         err := c.ch.SendRequest(in).ReceiveReply(out)
 115         if err != nil {
 116                 return nil, err
 117         }
 118         return out, nil
 119 }
 120
 121 func (c *serviceClient) SrPolicyAdd(ctx context.Context, in *SrPolicyAdd) (*SrPolicyAddReply, error) {
 122         out := new(SrPolicyAddReply)
 123         err := c.ch.SendRequest(in).ReceiveReply(out)
 124         if err != nil {
 125                 return nil, err
 126         }
 127         return out, nil
 128 }
 129
 130 func (c *serviceClient) SrPolicyDel(ctx context.Context, in *SrPolicyDel) (*SrPolicyDelReply, error) {
 131         out := new(SrPolicyDelReply)
 132         err := c.ch.SendRequest(in).ReceiveReply(out)
 133         if err != nil {
 134                 return nil, err
 135         }
 136         return out, nil
 137 }
 138
 139 func (c *serviceClient) SrPolicyMod(ctx context.Context, in *SrPolicyMod) (*SrPolicyModReply, error) {
 140         out := new(SrPolicyModReply)
 141         err := c.ch.SendRequest(in).ReceiveReply(out)
 142         if err != nil {
 143                 return nil, err
 144         }
 145         return out, nil
 146 }
 147
 148 func (c *serviceClient) SrSetEncapHopLimit(ctx context.Context, in *SrSetEncapHopLimit) (*SrSetEncapHopLimitReply, error) {
 149         out := new(SrSetEncapHopLimitReply)
 150         err := c.ch.SendRequest(in).ReceiveReply(out)
 151         if err != nil {
 152                 return nil, err
 153         }
 154         return out, nil
 155 }
 156
 157 func (c *serviceClient) SrSetEncapSource(ctx context.Context, in *SrSetEncapSource) (*SrSetEncapSourceReply, error) {
 158         out := new(SrSetEncapSourceReply)
 159         err := c.ch.SendRequest(in).ReceiveReply(out)
 160         if err != nil {
 161                 return nil, err
 162         }
 163         return out, nil
 164 }
 165
 166 func (c *serviceClient) SrSteeringAddDel(ctx context.Context, in *SrSteeringAddDel) (*SrSteeringAddDelReply, error) {
 167         out := new(SrSteeringAddDelReply)
 168         err := c.ch.SendRequest(in).ReceiveReply(out)
 169         if err != nil {
 170                 return nil, err
 171         }
 172         return out, nil
 173 }
 174
 175 // Reference imports to suppress errors if they are not otherwise used.
 176 var _ = api.RegisterMessage
 177 var _ = context.Background
 178 var _ = io.Copy