Versions in this module Expand all Collapse all v1 v1.0.3 Feb 27, 2025 Changes in this version + const EdgeAliveProto + const MinimumRelayConnections + const MinimumRelayNodes + var ErrMinBootnodes = errors.New("minimum 1 bootnode is required") + var ErrMinRelaynodes = errors.New("minimum 1 relaynode is required") + var ErrNoBootnodes = errors.New("no bootnodes specified") + var ErrNoRelaynodes = errors.New("no relaynodes specified") + type AliveService struct + func NewAliveService(server networkingServer, logger hclog.Logger, ...) *AliveService + func (d *AliveService) Hello(ctx context.Context, status *proto.AliveStatus) (*proto.AliveStatusResp, error) + type PeerConnInfo struct + Info peer.AddrInfo + type Protocol interface + Client func(network.Stream) *rawGrpc.ClientConn + Handler func() func(network.Stream) + type RelayClient struct + func NewRelayClient(logger hclog.Logger, config *emcNetwork.Config, relayOn bool, ...) (*RelayClient, error) + func (d *RelayClient) ConnectToBootnodes(bootnodes []*peer.AddrInfo) + func (m *RelayClient) Close() + func (s *RelayClient) AddToPeerStore(peerInfo *peer.AddrInfo) + func (s *RelayClient) CloseProtocolStream(protocol string, peerID peer.ID) error + func (s *RelayClient) GetBootnodes() []*peer.AddrInfo + func (s *RelayClient) GetHost() host.Host + func (s *RelayClient) GetNotifyBundle() *network.NotifyBundle + func (s *RelayClient) GetRandomBootnode() *peer.AddrInfo + func (s *RelayClient) GetRandomRelaynode() *peer.AddrInfo + func (s *RelayClient) GetRelayPeerInfo() *RelayPeerInfo + func (s *RelayClient) NewAliveClient(peerID peer.ID) (proto.AliveClient, error) + func (s *RelayClient) NewProtoConnection(protocol string, peerID peer.ID) (*rawGrpc.ClientConn, error) + func (s *RelayClient) NewStream(proto string, id peer.ID) (network.Stream, error) + func (s *RelayClient) RegisterProtocol(id string, p Protocol) + func (s *RelayClient) RelayPeers() []*RelayPeerInfo + func (s *RelayClient) RemoveFromPeerStore(peerInfo *peer.AddrInfo) + func (s *RelayClient) SaveProtocolStream(protocol string, stream *rawGrpc.ClientConn, peerID peer.ID) + func (s *RelayClient) StartAlive(subscription application.Subscription) error + func (s *RelayClient) StartRelayReserv() error + type RelayConnInfo struct + Info peer.AddrInfo + type RelayPeerInfo struct + Info *RelayConnInfo + Reservation *client.Reservation + type RelayServer struct + MaxReservations int + func NewRelayServer(logger hclog.Logger, secretsManager secrets.SecretsManager, ...) (*RelayServer, error) + func NewRelayServerWithHost(logger hclog.Logger, host host.Host) (*RelayServer, error) + func (s *RelayServer) GetHost() host.Host + func (s *RelayServer) GetNotifyBundle() *network.NotifyBundle + func (s *RelayServer) GetPeerAddrInfo(peerID peer.ID) peer.AddrInfo + func (s *RelayServer) GetRandomBootnode() *peer.AddrInfo + func (s *RelayServer) GetRelayProxyAddr() *net.TCPAddr + func (s *RelayServer) PublishApplicationStatus(status *appProto.AppStatus) + func (s *RelayServer) RegisterProtocol(id string, p Protocol) + func (s *RelayServer) SetupAliveService(syncAppPeerClient application.SyncAppPeerClient) error
Go to main page