rpc

package
v0.4.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 4, 2023 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Overview

Package rpc implements a gRPC client and server for management and monitoring of a cunicu daemon

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DaemonRunning 

func DaemonRunning(path string) bool

Types

type Client 

type Client struct {
	io.Closer

	rpcproto.EndpointDiscoverySocketClient
	rpcproto.SignalingClient
	rpcproto.DaemonClient
	// contains filtered or unexported fields
}

func Connect 

func Connect(path string) (*Client, error)

func (*Client) AddEventHandler 

func (c *Client) AddEventHandler(h EventHandler)

func (*Client) Close 

func (c *Client) Close() error

func (*Client) OnEvent 

func (c *Client) OnEvent(e *rpcproto.Event)

func (*Client) RemoveEventHandler 

func (c *Client) RemoveEventHandler(h EventHandler)

func (*Client) RestartPeer 

func (c *Client) RestartPeer(ctx context.Context, intf string, pk *crypto.Key) error

func (*Client) Unwait 

func (c *Client) Unwait() error

func (*Client) WaitForEvent 

func (c *Client) WaitForEvent(ctx context.Context, t rpcproto.EventType, intf string, peer crypto.Key) (*rpcproto.Event, error)

func (*Client) WaitForPeerHandshake 

func (c *Client) WaitForPeerHandshake(ctx context.Context, peer crypto.Key) error

func (*Client) WaitForPeerState 

func (c *Client) WaitForPeerState(ctx context.Context, peer crypto.Key, csd daemon.PeerState) error

type DaemonServer 

type DaemonServer struct {
	rpcproto.UnimplementedDaemonServer

	*Server
	*daemon.Daemon
}

func NewDaemonServer 

func NewDaemonServer(s *Server, d *daemon.Daemon) *DaemonServer

func (*DaemonServer) AddPeer 

func (s *DaemonServer) AddPeer(_ context.Context, params *rpcproto.AddPeerParams) (*rpcproto.AddPeerResp, error)

func (*DaemonServer) GetBuildInfo 

func (s *DaemonServer) GetBuildInfo(context.Context, *proto.Empty) (*proto.BuildInfo, error)

func (*DaemonServer) GetCompletion 

func (s *DaemonServer) GetCompletion(_ context.Context, params *rpcproto.GetCompletionParams) (*rpcproto.GetCompletionResp, error)

func (*DaemonServer) GetConfig 

func (s *DaemonServer) GetConfig(_ context.Context, p *rpcproto.GetConfigParams) (*rpcproto.GetConfigResp, error)

func (*DaemonServer) GetStatus 

func (s *DaemonServer) GetStatus(_ context.Context, p *rpcproto.GetStatusParams) (*rpcproto.GetStatusResp, error)

func (*DaemonServer) OnInterfaceAdded 

func (s *DaemonServer) OnInterfaceAdded(i *daemon.Interface)

func (*DaemonServer) OnInterfaceRemoved 

func (s *DaemonServer) OnInterfaceRemoved(_ *daemon.Interface)

func (*DaemonServer) OnPeerStateChanged 

func (s *DaemonServer) OnPeerStateChanged(p *daemon.Peer, newState, prevState daemon.PeerState)

func (*DaemonServer) ReloadConfig 

func (s *DaemonServer) ReloadConfig(_ context.Context, _ *proto.Empty) (*proto.Empty, error)

func (*DaemonServer) SendPeerStates 

func (s *DaemonServer) SendPeerStates(stream rpcproto.Daemon_StreamEventsServer)

func (*DaemonServer) SetConfig 

func (s *DaemonServer) SetConfig(_ context.Context, p *rpcproto.SetConfigParams) (*proto.Empty, error)

func (*DaemonServer) Shutdown 

func (s *DaemonServer) Shutdown(_ context.Context, params *rpcproto.ShutdownParams) (*proto.Empty, error)

func (*DaemonServer) StreamEvents 

func (s *DaemonServer) StreamEvents(_ *proto.Empty, stream rpcproto.Daemon_StreamEventsServer) error

func (*DaemonServer) Sync 

func (s *DaemonServer) Sync(_ context.Context, _ *proto.Empty) (*proto.Empty, error)

func (*DaemonServer) UnWait 

func (s *DaemonServer) UnWait(_ context.Context, _ *proto.Empty) (*proto.Empty, error)

type EndpointDiscoveryServer 

type EndpointDiscoveryServer struct {
	rpcproto.UnimplementedEndpointDiscoverySocketServer

	*Server
}

func NewEndpointDiscoveryServer 

func NewEndpointDiscoveryServer(s *Server) *EndpointDiscoveryServer

func (*EndpointDiscoveryServer) RestartPeer 

func (s *EndpointDiscoveryServer) RestartPeer(_ context.Context, params *rpcproto.RestartPeerParams) (*proto.Empty, error)

type Event 

type Event struct {
	rpcproto.Event
}

func (*Event) String 

func (e *Event) String() string

type EventHandler 

type EventHandler interface {
	OnEvent(*rpcproto.Event)
}

type Server 

type Server struct {
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(d *daemon.Daemon, socket string) (*Server, error)

func (*Server) Close 

func (s *Server) Close() error

func (*Server) OnInterfaceAdded 

func (s *Server) OnInterfaceAdded(i *daemon.Interface)

func (*Server) OnInterfaceModified 

func (s *Server) OnInterfaceModified(i *daemon.Interface, _ *wg.Interface, mod daemon.InterfaceModifier)

func (*Server) OnInterfaceRemoved 

func (s *Server) OnInterfaceRemoved(i *daemon.Interface)

func (*Server) OnPeerAdded 

func (s *Server) OnPeerAdded(p *daemon.Peer)

func (*Server) OnPeerModified 

func (s *Server) OnPeerModified(p *daemon.Peer, _ *wgtypes.Peer, mod daemon.PeerModifier, _, _ []net.IPNet)

func (*Server) OnPeerRemoved 

func (s *Server) OnPeerRemoved(p *daemon.Peer)

func (*Server) OnSignalingBackendReady 

func (s *Server) OnSignalingBackendReady(b signaling.Backend)

func (*Server) OnSignalingMessage 

func (s *Server) OnSignalingMessage(_ *crypto.PublicKeyPair, _ *signaling.Message)

func (*Server) Wait 

func (s *Server) Wait()

type SignalingServer 

type SignalingServer struct {
	rpcproto.UnimplementedSignalingServer

	*Server
	*grpc.Backend
}

func NewSignalingServer 

func NewSignalingServer(s *Server, b *signaling.MultiBackend) *SignalingServer

func (*SignalingServer) GetSignalingMessage 

func (s *SignalingServer) GetSignalingMessage(_ context.Context, _ *rpcproto.GetSignalingMessageParams) (*rpcproto.GetSignalingMessageResp, error)

func (*SignalingServer) PutSignalingMessage 

func (s *SignalingServer) PutSignalingMessage(_ context.Context, _ *rpcproto.PutSignalingMessageParams) (*proto.Empty, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.