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 wireguard.
15 type RPCService interface {
16 WantWireguardPeerEvents(ctx context.Context, in *WantWireguardPeerEvents) (*WantWireguardPeerEventsReply, error)
17 WgSetAsyncMode(ctx context.Context, in *WgSetAsyncMode) (*WgSetAsyncModeReply, error)
18 WireguardInterfaceCreate(ctx context.Context, in *WireguardInterfaceCreate) (*WireguardInterfaceCreateReply, error)
19 WireguardInterfaceDelete(ctx context.Context, in *WireguardInterfaceDelete) (*WireguardInterfaceDeleteReply, error)
20 WireguardInterfaceDump(ctx context.Context, in *WireguardInterfaceDump) (RPCService_WireguardInterfaceDumpClient, error)
21 WireguardPeerAdd(ctx context.Context, in *WireguardPeerAdd) (*WireguardPeerAddReply, error)
22 WireguardPeerRemove(ctx context.Context, in *WireguardPeerRemove) (*WireguardPeerRemoveReply, error)
23 WireguardPeersDump(ctx context.Context, in *WireguardPeersDump) (RPCService_WireguardPeersDumpClient, error)
26 type serviceClient struct {
30 func NewServiceClient(conn api.Connection) RPCService {
31 return &serviceClient{conn}
34 func (c *serviceClient) WantWireguardPeerEvents(ctx context.Context, in *WantWireguardPeerEvents) (*WantWireguardPeerEventsReply, error) {
35 out := new(WantWireguardPeerEventsReply)
36 err := c.conn.Invoke(ctx, in, out)
40 return out, api.RetvalToVPPApiError(out.Retval)
43 func (c *serviceClient) WgSetAsyncMode(ctx context.Context, in *WgSetAsyncMode) (*WgSetAsyncModeReply, error) {
44 out := new(WgSetAsyncModeReply)
45 err := c.conn.Invoke(ctx, in, out)
49 return out, api.RetvalToVPPApiError(out.Retval)
52 func (c *serviceClient) WireguardInterfaceCreate(ctx context.Context, in *WireguardInterfaceCreate) (*WireguardInterfaceCreateReply, error) {
53 out := new(WireguardInterfaceCreateReply)
54 err := c.conn.Invoke(ctx, in, out)
58 return out, api.RetvalToVPPApiError(out.Retval)
61 func (c *serviceClient) WireguardInterfaceDelete(ctx context.Context, in *WireguardInterfaceDelete) (*WireguardInterfaceDeleteReply, error) {
62 out := new(WireguardInterfaceDeleteReply)
63 err := c.conn.Invoke(ctx, in, out)
67 return out, api.RetvalToVPPApiError(out.Retval)
70 func (c *serviceClient) WireguardInterfaceDump(ctx context.Context, in *WireguardInterfaceDump) (RPCService_WireguardInterfaceDumpClient, error) {
71 stream, err := c.conn.NewStream(ctx)
75 x := &serviceClient_WireguardInterfaceDumpClient{stream}
76 if err := x.Stream.SendMsg(in); err != nil {
79 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
85 type RPCService_WireguardInterfaceDumpClient interface {
86 Recv() (*WireguardInterfaceDetails, error)
90 type serviceClient_WireguardInterfaceDumpClient struct {
94 func (c *serviceClient_WireguardInterfaceDumpClient) Recv() (*WireguardInterfaceDetails, error) {
95 msg, err := c.Stream.RecvMsg()
99 switch m := msg.(type) {
100 case *WireguardInterfaceDetails:
102 case *memclnt.ControlPingReply:
103 err = c.Stream.Close()
109 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
113 func (c *serviceClient) WireguardPeerAdd(ctx context.Context, in *WireguardPeerAdd) (*WireguardPeerAddReply, error) {
114 out := new(WireguardPeerAddReply)
115 err := c.conn.Invoke(ctx, in, out)
119 return out, api.RetvalToVPPApiError(out.Retval)
122 func (c *serviceClient) WireguardPeerRemove(ctx context.Context, in *WireguardPeerRemove) (*WireguardPeerRemoveReply, error) {
123 out := new(WireguardPeerRemoveReply)
124 err := c.conn.Invoke(ctx, in, out)
128 return out, api.RetvalToVPPApiError(out.Retval)
131 func (c *serviceClient) WireguardPeersDump(ctx context.Context, in *WireguardPeersDump) (RPCService_WireguardPeersDumpClient, error) {
132 stream, err := c.conn.NewStream(ctx)
136 x := &serviceClient_WireguardPeersDumpClient{stream}
137 if err := x.Stream.SendMsg(in); err != nil {
140 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
146 type RPCService_WireguardPeersDumpClient interface {
147 Recv() (*WireguardPeersDetails, error)
151 type serviceClient_WireguardPeersDumpClient struct {
155 func (c *serviceClient_WireguardPeersDumpClient) Recv() (*WireguardPeersDetails, error) {
156 msg, err := c.Stream.RecvMsg()
160 switch m := msg.(type) {
161 case *WireguardPeersDetails:
163 case *memclnt.ControlPingReply:
164 err = c.Stream.Close()
170 return nil, fmt.Errorf("unexpected message: %T %v", m, m)