1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "git.fd.io/govpp.git/api"
11 vpe "git.fd.io/govpp.git/internal/testbinapi/binapi2001/vpe"
14 // RPCService defines RPC service sr.
15 type RPCService interface {
16 SrLocalsidAddDel(ctx context.Context, in *SrLocalsidAddDel) (*SrLocalsidAddDelReply, error)
17 SrLocalsidsDump(ctx context.Context, in *SrLocalsidsDump) (RPCService_SrLocalsidsDumpClient, error)
18 SrPoliciesDump(ctx context.Context, in *SrPoliciesDump) (RPCService_SrPoliciesDumpClient, error)
19 SrPolicyAdd(ctx context.Context, in *SrPolicyAdd) (*SrPolicyAddReply, error)
20 SrPolicyDel(ctx context.Context, in *SrPolicyDel) (*SrPolicyDelReply, error)
21 SrPolicyMod(ctx context.Context, in *SrPolicyMod) (*SrPolicyModReply, error)
22 SrSetEncapHopLimit(ctx context.Context, in *SrSetEncapHopLimit) (*SrSetEncapHopLimitReply, error)
23 SrSetEncapSource(ctx context.Context, in *SrSetEncapSource) (*SrSetEncapSourceReply, error)
24 SrSteeringAddDel(ctx context.Context, in *SrSteeringAddDel) (*SrSteeringAddDelReply, error)
25 SrSteeringPolDump(ctx context.Context, in *SrSteeringPolDump) (RPCService_SrSteeringPolDumpClient, error)
28 type serviceClient struct {
32 func NewServiceClient(conn api.Connection) RPCService {
33 return &serviceClient{conn}
36 func (c *serviceClient) SrLocalsidAddDel(ctx context.Context, in *SrLocalsidAddDel) (*SrLocalsidAddDelReply, error) {
37 out := new(SrLocalsidAddDelReply)
38 err := c.conn.Invoke(ctx, in, out)
42 return out, api.RetvalToVPPApiError(out.Retval)
45 func (c *serviceClient) SrLocalsidsDump(ctx context.Context, in *SrLocalsidsDump) (RPCService_SrLocalsidsDumpClient, error) {
46 stream, err := c.conn.NewStream(ctx)
50 x := &serviceClient_SrLocalsidsDumpClient{stream}
51 if err := x.Stream.SendMsg(in); err != nil {
54 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
60 type RPCService_SrLocalsidsDumpClient interface {
61 Recv() (*SrLocalsidsDetails, error)
65 type serviceClient_SrLocalsidsDumpClient struct {
69 func (c *serviceClient_SrLocalsidsDumpClient) Recv() (*SrLocalsidsDetails, error) {
70 msg, err := c.Stream.RecvMsg()
74 switch m := msg.(type) {
75 case *SrLocalsidsDetails:
77 case *vpe.ControlPingReply:
78 err = c.Stream.Close()
84 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
88 func (c *serviceClient) SrPoliciesDump(ctx context.Context, in *SrPoliciesDump) (RPCService_SrPoliciesDumpClient, error) {
89 stream, err := c.conn.NewStream(ctx)
93 x := &serviceClient_SrPoliciesDumpClient{stream}
94 if err := x.Stream.SendMsg(in); err != nil {
97 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
103 type RPCService_SrPoliciesDumpClient interface {
104 Recv() (*SrPoliciesDetails, error)
108 type serviceClient_SrPoliciesDumpClient struct {
112 func (c *serviceClient_SrPoliciesDumpClient) Recv() (*SrPoliciesDetails, error) {
113 msg, err := c.Stream.RecvMsg()
117 switch m := msg.(type) {
118 case *SrPoliciesDetails:
120 case *vpe.ControlPingReply:
121 err = c.Stream.Close()
127 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
131 func (c *serviceClient) SrPolicyAdd(ctx context.Context, in *SrPolicyAdd) (*SrPolicyAddReply, error) {
132 out := new(SrPolicyAddReply)
133 err := c.conn.Invoke(ctx, in, out)
137 return out, api.RetvalToVPPApiError(out.Retval)
140 func (c *serviceClient) SrPolicyDel(ctx context.Context, in *SrPolicyDel) (*SrPolicyDelReply, error) {
141 out := new(SrPolicyDelReply)
142 err := c.conn.Invoke(ctx, in, out)
146 return out, api.RetvalToVPPApiError(out.Retval)
149 func (c *serviceClient) SrPolicyMod(ctx context.Context, in *SrPolicyMod) (*SrPolicyModReply, error) {
150 out := new(SrPolicyModReply)
151 err := c.conn.Invoke(ctx, in, out)
155 return out, api.RetvalToVPPApiError(out.Retval)
158 func (c *serviceClient) SrSetEncapHopLimit(ctx context.Context, in *SrSetEncapHopLimit) (*SrSetEncapHopLimitReply, error) {
159 out := new(SrSetEncapHopLimitReply)
160 err := c.conn.Invoke(ctx, in, out)
164 return out, api.RetvalToVPPApiError(out.Retval)
167 func (c *serviceClient) SrSetEncapSource(ctx context.Context, in *SrSetEncapSource) (*SrSetEncapSourceReply, error) {
168 out := new(SrSetEncapSourceReply)
169 err := c.conn.Invoke(ctx, in, out)
173 return out, api.RetvalToVPPApiError(out.Retval)
176 func (c *serviceClient) SrSteeringAddDel(ctx context.Context, in *SrSteeringAddDel) (*SrSteeringAddDelReply, error) {
177 out := new(SrSteeringAddDelReply)
178 err := c.conn.Invoke(ctx, in, out)
182 return out, api.RetvalToVPPApiError(out.Retval)
185 func (c *serviceClient) SrSteeringPolDump(ctx context.Context, in *SrSteeringPolDump) (RPCService_SrSteeringPolDumpClient, error) {
186 stream, err := c.conn.NewStream(ctx)
190 x := &serviceClient_SrSteeringPolDumpClient{stream}
191 if err := x.Stream.SendMsg(in); err != nil {
194 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
200 type RPCService_SrSteeringPolDumpClient interface {
201 Recv() (*SrSteeringPolDetails, error)
205 type serviceClient_SrSteeringPolDumpClient struct {
209 func (c *serviceClient_SrSteeringPolDumpClient) Recv() (*SrSteeringPolDetails, error) {
210 msg, err := c.Stream.RecvMsg()
214 switch m := msg.(type) {
215 case *SrSteeringPolDetails:
217 case *vpe.ControlPingReply:
218 err = c.Stream.Close()
224 return nil, fmt.Errorf("unexpected message: %T %v", m, m)