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/binapi/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:
80 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
84 func (c *serviceClient) SrPoliciesDump(ctx context.Context, in *SrPoliciesDump) (RPCService_SrPoliciesDumpClient, error) {
85 stream, err := c.conn.NewStream(ctx)
89 x := &serviceClient_SrPoliciesDumpClient{stream}
90 if err := x.Stream.SendMsg(in); err != nil {
93 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
99 type RPCService_SrPoliciesDumpClient interface {
100 Recv() (*SrPoliciesDetails, error)
104 type serviceClient_SrPoliciesDumpClient struct {
108 func (c *serviceClient_SrPoliciesDumpClient) Recv() (*SrPoliciesDetails, error) {
109 msg, err := c.Stream.RecvMsg()
113 switch m := msg.(type) {
114 case *SrPoliciesDetails:
116 case *vpe.ControlPingReply:
119 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
123 func (c *serviceClient) SrPolicyAdd(ctx context.Context, in *SrPolicyAdd) (*SrPolicyAddReply, error) {
124 out := new(SrPolicyAddReply)
125 err := c.conn.Invoke(ctx, in, out)
129 return out, api.RetvalToVPPApiError(out.Retval)
132 func (c *serviceClient) SrPolicyDel(ctx context.Context, in *SrPolicyDel) (*SrPolicyDelReply, error) {
133 out := new(SrPolicyDelReply)
134 err := c.conn.Invoke(ctx, in, out)
138 return out, api.RetvalToVPPApiError(out.Retval)
141 func (c *serviceClient) SrPolicyMod(ctx context.Context, in *SrPolicyMod) (*SrPolicyModReply, error) {
142 out := new(SrPolicyModReply)
143 err := c.conn.Invoke(ctx, in, out)
147 return out, api.RetvalToVPPApiError(out.Retval)
150 func (c *serviceClient) SrSetEncapHopLimit(ctx context.Context, in *SrSetEncapHopLimit) (*SrSetEncapHopLimitReply, error) {
151 out := new(SrSetEncapHopLimitReply)
152 err := c.conn.Invoke(ctx, in, out)
156 return out, api.RetvalToVPPApiError(out.Retval)
159 func (c *serviceClient) SrSetEncapSource(ctx context.Context, in *SrSetEncapSource) (*SrSetEncapSourceReply, error) {
160 out := new(SrSetEncapSourceReply)
161 err := c.conn.Invoke(ctx, in, out)
165 return out, api.RetvalToVPPApiError(out.Retval)
168 func (c *serviceClient) SrSteeringAddDel(ctx context.Context, in *SrSteeringAddDel) (*SrSteeringAddDelReply, error) {
169 out := new(SrSteeringAddDelReply)
170 err := c.conn.Invoke(ctx, in, out)
174 return out, api.RetvalToVPPApiError(out.Retval)
177 func (c *serviceClient) SrSteeringPolDump(ctx context.Context, in *SrSteeringPolDump) (RPCService_SrSteeringPolDumpClient, error) {
178 stream, err := c.conn.NewStream(ctx)
182 x := &serviceClient_SrSteeringPolDumpClient{stream}
183 if err := x.Stream.SendMsg(in); err != nil {
186 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
192 type RPCService_SrSteeringPolDumpClient interface {
193 Recv() (*SrSteeringPolDetails, error)
197 type serviceClient_SrSteeringPolDumpClient struct {
201 func (c *serviceClient_SrSteeringPolDumpClient) Recv() (*SrSteeringPolDetails, error) {
202 msg, err := c.Stream.RecvMsg()
206 switch m := msg.(type) {
207 case *SrSteeringPolDetails:
209 case *vpe.ControlPingReply:
212 return nil, fmt.Errorf("unexpected message: %T %v", m, m)