peer

Documentation

Index

• type Peer
  • func NewPeer(id string, stream proto.SignalExchange_ConnectStreamServer) *Peer
• 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)

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
}

Peer representation of a connected Peer

func NewPeer

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

NewPeer creates a new instance of a connected Peer

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)

Register registers peer in the registry