peer

Documentation

Index

• Variables
• type Peer
  • func NewPeer(id string, stream proto.SignalExchange_ConnectStreamServer, ...) *Peer
  • func (p *Peer) Send(msg *proto.EncryptedMessage) error
• type Registry
  • func NewRegistry(metrics *metrics.AppMetrics) *Registry
  • func (registry *Registry) Deregister(peer *Peer)
  • func (registry *Registry) Get(peerId string) (*Peer, bool)
  • func (registry *Registry) IsPeerRegistered(peerId string) bool
  • func (registry *Registry) Register(peer *Peer) error

Variables

var (
	ErrPeerAlreadyRegistered = errors.New("peer already registered")
)

Types

type Peer

type Peer struct {
	// a unique id of the Peer (e.g. sha256 fingerprint of the Wireguard public key)
	Id string

	StreamID int64

	// a gRpc connection stream to the Peer
	Stream proto.SignalExchange_ConnectStreamServer

	// registration time
	RegisteredAt time.Time

	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

Peer representation of a connected Peer

func NewPeer

func NewPeer(id string, stream proto.SignalExchange_ConnectStreamServer, cancel context.CancelFunc) *Peer

NewPeer creates a new instance of a connected Peer

func (*Peer) Send

func (p *Peer) Send(msg *proto.EncryptedMessage) error

Send writes a message to the peer's stream, serializing concurrent senders.

type Registry

type Registry struct {
	// Peer.key -> Peer
	Peers sync.Map
	// contains filtered or unexported fields
}

Registry that holds all currently connected Peers

func NewRegistry

func NewRegistry(metrics *metrics.AppMetrics) *Registry

NewRegistry creates a new connected Peer registry

func (*Registry) Deregister

func (registry *Registry) Deregister(peer *Peer)

Deregister Peer from the Registry (usually once it disconnects)

func (*Registry) Get

func (registry *Registry) Get(peerId string) (*Peer, bool)

Get gets a peer from the registry

func (*Registry) IsPeerRegistered

func (registry *Registry) IsPeerRegistered(peerId string) bool

func (*Registry) Register

func (registry *Registry) Register(peer *Peer) error

Register registers peer in the registry