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 session.
15 type RPCService interface {
16 AppAddCertKeyPair(ctx context.Context, in *AppAddCertKeyPair) (*AppAddCertKeyPairReply, error)
17 AppAttach(ctx context.Context, in *AppAttach) (*AppAttachReply, error)
18 AppDelCertKeyPair(ctx context.Context, in *AppDelCertKeyPair) (*AppDelCertKeyPairReply, error)
19 AppNamespaceAddDel(ctx context.Context, in *AppNamespaceAddDel) (*AppNamespaceAddDelReply, error)
20 AppWorkerAddDel(ctx context.Context, in *AppWorkerAddDel) (*AppWorkerAddDelReply, error)
21 ApplicationDetach(ctx context.Context, in *ApplicationDetach) (*ApplicationDetachReply, error)
22 ApplicationTLSCertAdd(ctx context.Context, in *ApplicationTLSCertAdd) (*ApplicationTLSCertAddReply, error)
23 ApplicationTLSKeyAdd(ctx context.Context, in *ApplicationTLSKeyAdd) (*ApplicationTLSKeyAddReply, error)
24 SessionEnableDisable(ctx context.Context, in *SessionEnableDisable) (*SessionEnableDisableReply, error)
25 SessionRuleAddDel(ctx context.Context, in *SessionRuleAddDel) (*SessionRuleAddDelReply, error)
26 SessionRulesDump(ctx context.Context, in *SessionRulesDump) (RPCService_SessionRulesDumpClient, error)
29 type serviceClient struct {
33 func NewServiceClient(conn api.Connection) RPCService {
34 return &serviceClient{conn}
37 func (c *serviceClient) AppAddCertKeyPair(ctx context.Context, in *AppAddCertKeyPair) (*AppAddCertKeyPairReply, error) {
38 out := new(AppAddCertKeyPairReply)
39 err := c.conn.Invoke(ctx, in, out)
43 return out, api.RetvalToVPPApiError(out.Retval)
46 func (c *serviceClient) AppAttach(ctx context.Context, in *AppAttach) (*AppAttachReply, error) {
47 out := new(AppAttachReply)
48 err := c.conn.Invoke(ctx, in, out)
52 return out, api.RetvalToVPPApiError(out.Retval)
55 func (c *serviceClient) AppDelCertKeyPair(ctx context.Context, in *AppDelCertKeyPair) (*AppDelCertKeyPairReply, error) {
56 out := new(AppDelCertKeyPairReply)
57 err := c.conn.Invoke(ctx, in, out)
61 return out, api.RetvalToVPPApiError(out.Retval)
64 func (c *serviceClient) AppNamespaceAddDel(ctx context.Context, in *AppNamespaceAddDel) (*AppNamespaceAddDelReply, error) {
65 out := new(AppNamespaceAddDelReply)
66 err := c.conn.Invoke(ctx, in, out)
70 return out, api.RetvalToVPPApiError(out.Retval)
73 func (c *serviceClient) AppWorkerAddDel(ctx context.Context, in *AppWorkerAddDel) (*AppWorkerAddDelReply, error) {
74 out := new(AppWorkerAddDelReply)
75 err := c.conn.Invoke(ctx, in, out)
79 return out, api.RetvalToVPPApiError(out.Retval)
82 func (c *serviceClient) ApplicationDetach(ctx context.Context, in *ApplicationDetach) (*ApplicationDetachReply, error) {
83 out := new(ApplicationDetachReply)
84 err := c.conn.Invoke(ctx, in, out)
88 return out, api.RetvalToVPPApiError(out.Retval)
91 func (c *serviceClient) ApplicationTLSCertAdd(ctx context.Context, in *ApplicationTLSCertAdd) (*ApplicationTLSCertAddReply, error) {
92 out := new(ApplicationTLSCertAddReply)
93 err := c.conn.Invoke(ctx, in, out)
97 return out, api.RetvalToVPPApiError(out.Retval)
100 func (c *serviceClient) ApplicationTLSKeyAdd(ctx context.Context, in *ApplicationTLSKeyAdd) (*ApplicationTLSKeyAddReply, error) {
101 out := new(ApplicationTLSKeyAddReply)
102 err := c.conn.Invoke(ctx, in, out)
106 return out, api.RetvalToVPPApiError(out.Retval)
109 func (c *serviceClient) SessionEnableDisable(ctx context.Context, in *SessionEnableDisable) (*SessionEnableDisableReply, error) {
110 out := new(SessionEnableDisableReply)
111 err := c.conn.Invoke(ctx, in, out)
115 return out, api.RetvalToVPPApiError(out.Retval)
118 func (c *serviceClient) SessionRuleAddDel(ctx context.Context, in *SessionRuleAddDel) (*SessionRuleAddDelReply, error) {
119 out := new(SessionRuleAddDelReply)
120 err := c.conn.Invoke(ctx, in, out)
124 return out, api.RetvalToVPPApiError(out.Retval)
127 func (c *serviceClient) SessionRulesDump(ctx context.Context, in *SessionRulesDump) (RPCService_SessionRulesDumpClient, error) {
128 stream, err := c.conn.NewStream(ctx)
132 x := &serviceClient_SessionRulesDumpClient{stream}
133 if err := x.Stream.SendMsg(in); err != nil {
136 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
142 type RPCService_SessionRulesDumpClient interface {
143 Recv() (*SessionRulesDetails, error)
147 type serviceClient_SessionRulesDumpClient struct {
151 func (c *serviceClient_SessionRulesDumpClient) Recv() (*SessionRulesDetails, error) {
152 msg, err := c.Stream.RecvMsg()
156 switch m := msg.(type) {
157 case *SessionRulesDetails:
159 case *vpe.ControlPingReply:
160 err = c.Stream.Close()
166 return nil, fmt.Errorf("unexpected message: %T %v", m, m)