peermap

Documentation

Index

• type Config
  • func ReadConfig(configFile string) (cfg Config, err error)
  • func (cfg *Config) Overwrite(cfg1 Config)
• type Peer
  • func (p *Peer) Close() error
  • func (p *Peer) Read(b []byte) (n int, err error)
  • func (p *Peer) Start()
  • func (p *Peer) String() string
  • func (p *Peer) Write(b []byte) (n int, err error)
• type PeerMap
  • func New(server *http.Server, cfg Config) (*PeerMap, error)
  • func (pm *PeerMap) FindPeer(network string, filter func(url.Values) bool) ([]*Peer, error)
  • func (pm *PeerMap) GetPeer(network string, peerID peer.ID) (*Peer, error)
  • func (pm *PeerMap) HandleOIDCAuthorize(w http.ResponseWriter, r *http.Request)
  • func (pm *PeerMap) HandlePeerPacketConnect(w http.ResponseWriter, r *http.Request)
  • func (pm *PeerMap) HandleQueryNetworkPeers(w http.ResponseWriter, r *http.Request)
  • func (pm *PeerMap) HandleQueryNetworks(w http.ResponseWriter, r *http.Request)
  • func (pm *PeerMap) Serve(ctx context.Context) error
• type RateLimiter

Types

type Config

type Config struct {
	Listen        string                    `yaml:"listen"`
	SecretKey     string                    `yaml:"secret_key"`
	STUNs         []string                  `yaml:"stuns"`
	PublicNetwork string                    `yaml:"public_network"`
	OIDCProviders []oidc.OIDCProviderConfig `yaml:"oidc_providers"`
	RateLimiter   *RateLimiter              `yaml:"rate_limiter,omitempty"`
}

func ReadConfig

func ReadConfig(configFile string) (cfg Config, err error)

func (*Config) Overwrite

func (cfg *Config) Overwrite(cfg1 Config)

type Peer

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

func (*Peer) Close

func (p *Peer) Close() error

func (*Peer) Read

func (p *Peer) Read(b []byte) (n int, err error)

func (*Peer) Start

func (p *Peer) Start()

func (*Peer) String

func (p *Peer) String() string

func (*Peer) Write

func (p *Peer) Write(b []byte) (n int, err error)

type PeerMap

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

func New

func New(server *http.Server, cfg Config) (*PeerMap, error)

func (*PeerMap) FindPeer

func (pm *PeerMap) FindPeer(network string, filter func(url.Values) bool) ([]*Peer, error)

func (*PeerMap) GetPeer

func (pm *PeerMap) GetPeer(network string, peerID peer.ID) (*Peer, error)

func (*PeerMap) HandleOIDCAuthorize

func (pm *PeerMap) HandleOIDCAuthorize(w http.ResponseWriter, r *http.Request)

func (*PeerMap) HandlePeerPacketConnect

func (pm *PeerMap) HandlePeerPacketConnect(w http.ResponseWriter, r *http.Request)

func (*PeerMap) HandleQueryNetworkPeers

func (pm *PeerMap) HandleQueryNetworkPeers(w http.ResponseWriter, r *http.Request)

func (*PeerMap) HandleQueryNetworks

func (pm *PeerMap) HandleQueryNetworks(w http.ResponseWriter, r *http.Request)

func (*PeerMap) Serve

func (pm *PeerMap) Serve(ctx context.Context) error

type RateLimiter

type RateLimiter struct {
	Limit int
	Burst int
}