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 cnat.
15 type RPCService interface {
16 CnatGetSnatAddresses(ctx context.Context, in *CnatGetSnatAddresses) (*CnatGetSnatAddressesReply, error)
17 CnatSessionDump(ctx context.Context, in *CnatSessionDump) (RPCService_CnatSessionDumpClient, error)
18 CnatSessionPurge(ctx context.Context, in *CnatSessionPurge) (*CnatSessionPurgeReply, error)
19 CnatSetSnatAddresses(ctx context.Context, in *CnatSetSnatAddresses) (*CnatSetSnatAddressesReply, error)
20 CnatSetSnatPolicy(ctx context.Context, in *CnatSetSnatPolicy) (*CnatSetSnatPolicyReply, error)
21 CnatSnatPolicyAddDelExcludePfx(ctx context.Context, in *CnatSnatPolicyAddDelExcludePfx) (*CnatSnatPolicyAddDelExcludePfxReply, error)
22 CnatSnatPolicyAddDelIf(ctx context.Context, in *CnatSnatPolicyAddDelIf) (*CnatSnatPolicyAddDelIfReply, error)
23 CnatTranslationDel(ctx context.Context, in *CnatTranslationDel) (*CnatTranslationDelReply, error)
24 CnatTranslationDump(ctx context.Context, in *CnatTranslationDump) (RPCService_CnatTranslationDumpClient, error)
25 CnatTranslationUpdate(ctx context.Context, in *CnatTranslationUpdate) (*CnatTranslationUpdateReply, error)
28 type serviceClient struct {
32 func NewServiceClient(conn api.Connection) RPCService {
33 return &serviceClient{conn}
36 func (c *serviceClient) CnatGetSnatAddresses(ctx context.Context, in *CnatGetSnatAddresses) (*CnatGetSnatAddressesReply, error) {
37 out := new(CnatGetSnatAddressesReply)
38 err := c.conn.Invoke(ctx, in, out)
42 return out, api.RetvalToVPPApiError(out.Retval)
45 func (c *serviceClient) CnatSessionDump(ctx context.Context, in *CnatSessionDump) (RPCService_CnatSessionDumpClient, error) {
46 stream, err := c.conn.NewStream(ctx)
50 x := &serviceClient_CnatSessionDumpClient{stream}
51 if err := x.Stream.SendMsg(in); err != nil {
54 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
60 type RPCService_CnatSessionDumpClient interface {
61 Recv() (*CnatSessionDetails, error)
65 type serviceClient_CnatSessionDumpClient struct {
69 func (c *serviceClient_CnatSessionDumpClient) Recv() (*CnatSessionDetails, error) {
70 msg, err := c.Stream.RecvMsg()
74 switch m := msg.(type) {
75 case *CnatSessionDetails:
77 case *vpe.ControlPingReply:
80 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
84 func (c *serviceClient) CnatSessionPurge(ctx context.Context, in *CnatSessionPurge) (*CnatSessionPurgeReply, error) {
85 out := new(CnatSessionPurgeReply)
86 err := c.conn.Invoke(ctx, in, out)
90 return out, api.RetvalToVPPApiError(out.Retval)
93 func (c *serviceClient) CnatSetSnatAddresses(ctx context.Context, in *CnatSetSnatAddresses) (*CnatSetSnatAddressesReply, error) {
94 out := new(CnatSetSnatAddressesReply)
95 err := c.conn.Invoke(ctx, in, out)
99 return out, api.RetvalToVPPApiError(out.Retval)
102 func (c *serviceClient) CnatSetSnatPolicy(ctx context.Context, in *CnatSetSnatPolicy) (*CnatSetSnatPolicyReply, error) {
103 out := new(CnatSetSnatPolicyReply)
104 err := c.conn.Invoke(ctx, in, out)
108 return out, api.RetvalToVPPApiError(out.Retval)
111 func (c *serviceClient) CnatSnatPolicyAddDelExcludePfx(ctx context.Context, in *CnatSnatPolicyAddDelExcludePfx) (*CnatSnatPolicyAddDelExcludePfxReply, error) {
112 out := new(CnatSnatPolicyAddDelExcludePfxReply)
113 err := c.conn.Invoke(ctx, in, out)
117 return out, api.RetvalToVPPApiError(out.Retval)
120 func (c *serviceClient) CnatSnatPolicyAddDelIf(ctx context.Context, in *CnatSnatPolicyAddDelIf) (*CnatSnatPolicyAddDelIfReply, error) {
121 out := new(CnatSnatPolicyAddDelIfReply)
122 err := c.conn.Invoke(ctx, in, out)
126 return out, api.RetvalToVPPApiError(out.Retval)
129 func (c *serviceClient) CnatTranslationDel(ctx context.Context, in *CnatTranslationDel) (*CnatTranslationDelReply, error) {
130 out := new(CnatTranslationDelReply)
131 err := c.conn.Invoke(ctx, in, out)
135 return out, api.RetvalToVPPApiError(out.Retval)
138 func (c *serviceClient) CnatTranslationDump(ctx context.Context, in *CnatTranslationDump) (RPCService_CnatTranslationDumpClient, error) {
139 stream, err := c.conn.NewStream(ctx)
143 x := &serviceClient_CnatTranslationDumpClient{stream}
144 if err := x.Stream.SendMsg(in); err != nil {
147 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
153 type RPCService_CnatTranslationDumpClient interface {
154 Recv() (*CnatTranslationDetails, error)
158 type serviceClient_CnatTranslationDumpClient struct {
162 func (c *serviceClient_CnatTranslationDumpClient) Recv() (*CnatTranslationDetails, error) {
163 msg, err := c.Stream.RecvMsg()
167 switch m := msg.(type) {
168 case *CnatTranslationDetails:
170 case *vpe.ControlPingReply:
173 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
177 func (c *serviceClient) CnatTranslationUpdate(ctx context.Context, in *CnatTranslationUpdate) (*CnatTranslationUpdateReply, error) {
178 out := new(CnatTranslationUpdateReply)
179 err := c.conn.Invoke(ctx, in, out)
183 return out, api.RetvalToVPPApiError(out.Retval)