1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "go.fd.io/govpp/api"
11 memclnt "go.fd.io/govpp/binapi/memclnt"
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(&memclnt.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 *memclnt.ControlPingReply:
78 err = c.Stream.Close()
84 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
88 func (c *serviceClient) CnatSessionPurge(ctx context.Context, in *CnatSessionPurge) (*CnatSessionPurgeReply, error) {
89 out := new(CnatSessionPurgeReply)
90 err := c.conn.Invoke(ctx, in, out)
94 return out, api.RetvalToVPPApiError(out.Retval)
97 func (c *serviceClient) CnatSetSnatAddresses(ctx context.Context, in *CnatSetSnatAddresses) (*CnatSetSnatAddressesReply, error) {
98 out := new(CnatSetSnatAddressesReply)
99 err := c.conn.Invoke(ctx, in, out)
103 return out, api.RetvalToVPPApiError(out.Retval)
106 func (c *serviceClient) CnatSetSnatPolicy(ctx context.Context, in *CnatSetSnatPolicy) (*CnatSetSnatPolicyReply, error) {
107 out := new(CnatSetSnatPolicyReply)
108 err := c.conn.Invoke(ctx, in, out)
112 return out, api.RetvalToVPPApiError(out.Retval)
115 func (c *serviceClient) CnatSnatPolicyAddDelExcludePfx(ctx context.Context, in *CnatSnatPolicyAddDelExcludePfx) (*CnatSnatPolicyAddDelExcludePfxReply, error) {
116 out := new(CnatSnatPolicyAddDelExcludePfxReply)
117 err := c.conn.Invoke(ctx, in, out)
121 return out, api.RetvalToVPPApiError(out.Retval)
124 func (c *serviceClient) CnatSnatPolicyAddDelIf(ctx context.Context, in *CnatSnatPolicyAddDelIf) (*CnatSnatPolicyAddDelIfReply, error) {
125 out := new(CnatSnatPolicyAddDelIfReply)
126 err := c.conn.Invoke(ctx, in, out)
130 return out, api.RetvalToVPPApiError(out.Retval)
133 func (c *serviceClient) CnatTranslationDel(ctx context.Context, in *CnatTranslationDel) (*CnatTranslationDelReply, error) {
134 out := new(CnatTranslationDelReply)
135 err := c.conn.Invoke(ctx, in, out)
139 return out, api.RetvalToVPPApiError(out.Retval)
142 func (c *serviceClient) CnatTranslationDump(ctx context.Context, in *CnatTranslationDump) (RPCService_CnatTranslationDumpClient, error) {
143 stream, err := c.conn.NewStream(ctx)
147 x := &serviceClient_CnatTranslationDumpClient{stream}
148 if err := x.Stream.SendMsg(in); err != nil {
151 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
157 type RPCService_CnatTranslationDumpClient interface {
158 Recv() (*CnatTranslationDetails, error)
162 type serviceClient_CnatTranslationDumpClient struct {
166 func (c *serviceClient_CnatTranslationDumpClient) Recv() (*CnatTranslationDetails, error) {
167 msg, err := c.Stream.RecvMsg()
171 switch m := msg.(type) {
172 case *CnatTranslationDetails:
174 case *memclnt.ControlPingReply:
175 err = c.Stream.Close()
181 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
185 func (c *serviceClient) CnatTranslationUpdate(ctx context.Context, in *CnatTranslationUpdate) (*CnatTranslationUpdateReply, error) {
186 out := new(CnatTranslationUpdateReply)
187 err := c.conn.Invoke(ctx, in, out)
191 return out, api.RetvalToVPPApiError(out.Retval)