rpc

Documentation

Overview

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

Index

• func DaemonRunning(path string) bool
• type Client
  • func Connect(path string) (*Client, error)
  • func (c *Client) AddEventHandler(h EventHandler)
  • func (c *Client) Close() error
  • func (c *Client) OnEvent(e *rpcproto.Event)
  • func (c *Client) RemoveEventHandler(h EventHandler)
  • func (c *Client) RestartPeer(ctx context.Context, intf string, pk *crypto.Key) error
  • func (c *Client) Unwait() error
  • func (c *Client) WaitForEvent(ctx context.Context, t rpcproto.EventType, intf string, peer crypto.Key) (*rpcproto.Event, error)
  • func (c *Client) WaitForPeerHandshake(ctx context.Context, peer crypto.Key) error
  • func (c *Client) WaitForPeerState(ctx context.Context, peer crypto.Key, csd daemon.PeerState) error
• type DaemonServer
  • func NewDaemonServer(s *Server, d *daemon.Daemon) *DaemonServer
  • func (s *DaemonServer) AddPeer(_ context.Context, params *rpcproto.AddPeerParams) (*rpcproto.AddPeerResp, error)
  • func (s *DaemonServer) GetBuildInfo(context.Context, *proto.Empty) (*proto.BuildInfo, error)
  • func (s *DaemonServer) GetCompletion(_ context.Context, params *rpcproto.GetCompletionParams) (*rpcproto.GetCompletionResp, error)
  • func (s *DaemonServer) GetConfig(_ context.Context, p *rpcproto.GetConfigParams) (*rpcproto.GetConfigResp, error)
  • func (s *DaemonServer) GetStatus(_ context.Context, p *rpcproto.GetStatusParams) (*rpcproto.GetStatusResp, error)
  • func (s *DaemonServer) OnInterfaceAdded(i *daemon.Interface)
  • func (s *DaemonServer) OnInterfaceRemoved(_ *daemon.Interface)
  • func (s *DaemonServer) OnPeerStateChanged(p *daemon.Peer, newState, prevState daemon.PeerState)
  • func (s *DaemonServer) ReloadConfig(_ context.Context, _ *proto.Empty) (*proto.Empty, error)
  • func (s *DaemonServer) SendPeerStates(stream rpcproto.Daemon_StreamEventsServer)
  • func (s *DaemonServer) SetConfig(_ context.Context, p *rpcproto.SetConfigParams) (*proto.Empty, error)
  • func (s *DaemonServer) Shutdown(_ context.Context, params *rpcproto.ShutdownParams) (*proto.Empty, error)
  • func (s *DaemonServer) StreamEvents(_ *proto.Empty, stream rpcproto.Daemon_StreamEventsServer) error
  • func (s *DaemonServer) Sync(_ context.Context, _ *proto.Empty) (*proto.Empty, error)
  • func (s *DaemonServer) UnWait(_ context.Context, _ *proto.Empty) (*proto.Empty, error)
• type EndpointDiscoveryServer
  • func NewEndpointDiscoveryServer(s *Server) *EndpointDiscoveryServer
  • func (s *EndpointDiscoveryServer) RestartPeer(_ context.Context, params *rpcproto.RestartPeerParams) (*proto.Empty, error)
• type Event
  • func (e *Event) String() string
• type EventHandler
• type Server
  • func NewServer(d *daemon.Daemon, socket string) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) OnInterfaceAdded(i *daemon.Interface)
  • func (s *Server) OnInterfaceModified(i *daemon.Interface, _ *wg.Interface, mod daemon.InterfaceModifier)
  • func (s *Server) OnInterfaceRemoved(i *daemon.Interface)
  • func (s *Server) OnPeerAdded(p *daemon.Peer)
  • func (s *Server) OnPeerModified(p *daemon.Peer, _ *wgtypes.Peer, mod daemon.PeerModifier, _, _ []net.IPNet)
  • func (s *Server) OnPeerRemoved(p *daemon.Peer)
  • func (s *Server) OnSignalingBackendReady(b signaling.Backend)
  • func (s *Server) OnSignalingMessage(_ *crypto.PublicKeyPair, _ *signaling.Message)
  • func (s *Server) Wait()
• type SignalingServer
  • func NewSignalingServer(s *Server, b *signaling.MultiBackend) *SignalingServer
  • func (s *SignalingServer) GetSignalingMessage(_ context.Context, _ *rpcproto.GetSignalingMessageParams) (*rpcproto.GetSignalingMessageResp, error)
  • func (s *SignalingServer) PutSignalingMessage(_ context.Context, _ *rpcproto.PutSignalingMessageParams) (*proto.Empty, error)

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)