comm

package

Go to main page

Versions in this module

v0

v0.4.0

Jan 6, 2025

Changes in this version

+ func P2PLayerTestRound(t *testing.T, bootstrapNode *HostNode, node *HostNode)

+ func SessionsForMPCTestRound(t *testing.T, bootstrapNode *HostNode, node *HostNode)

+ func SessionsTestRound(t *testing.T, bootstrapNode *HostNode, node *HostNode)

type ConfigService

+ GetPath func(key string) string

+ type HostNode struct

+ Address host2.PeerIPAddress

+ ID host2.PeerID

type Metrics

+ ActiveStreams metrics.Gauge

+ ClosedStreams metrics.Counter

+ OpenedStreams metrics.Counter

+ Sessions metrics.Gauge

+ StreamHandlers metrics.Gauge

+ StreamHashes metrics.Gauge

type NetworkStreamSession

+ func (n *NetworkStreamSession) SendErrorWithContext(ctx context.Context, payload []byte) error

+ func (n *NetworkStreamSession) SendWithContext(ctx context.Context, payload []byte) error

+ type PKExtractor struct

+ func (p *PKExtractor) ExtractPublicKey(id view.Identity) (any, error)

type Service

+ HostProvider host.GeneratorProvider

v0.3.0

Oct 5, 2023

Changes in this version

+ const PeerId

+ const ProtocolId

+ type Metrics struct

+ BytesReceived metrics.Counter

+ BytesSent metrics.Counter

+ func NewMetrics(p metrics.Provider) *Metrics

+ type MetricsReporter struct

+ func NewReporter(m *Metrics) *MetricsReporter

+ func (r *MetricsReporter) GetBandwidthByPeer() map[peer.ID]metrics.Stats

+ func (r *MetricsReporter) GetBandwidthByProtocol() map[protocol.ID]metrics.Stats

+ func (r *MetricsReporter) GetBandwidthForPeer(peer.ID) metrics.Stats

+ func (r *MetricsReporter) GetBandwidthForProtocol(protocol.ID) metrics.Stats

+ func (r *MetricsReporter) GetBandwidthTotals() metrics.Stats

+ func (r *MetricsReporter) LogRecvMessage(int64)

+ func (r *MetricsReporter) LogRecvMessageStream(size int64, proto protocol.ID, p peer.ID)

+ func (r *MetricsReporter) LogSentMessage(int64)

+ func (r *MetricsReporter) LogSentMessageStream(size int64, proto protocol.ID, p peer.ID)

type Service

+ Metrics *Metrics

+ NodeSync sync.RWMutex

+ func (s *Service) Addresses(id view2.Identity) ([]string, error)

v0.2.0

Dec 7, 2022

v0.1.0

Nov 16, 2022

Changes in this version

+ const NonceSize

+ var File_messages_proto protoreflect.FileDescriptor

+ func AddressToEndpoint(endpoint string) (string, error)

+ func GetRandomBytes(len int) ([]byte, error)

+ func GetRandomNonce() ([]byte, error)

+ func NewDelimitedReader(r io2.Reader, maxSize int) io.ReadCloser

+ type ConfigService interface

+ GetString func(key string) string

+ type EndpointService interface

+ GetIdentity func(label string, pkID []byte) (view2.Identity, error)

+ Resolve func(party view2.Identity) (view2.Identity, map[view.PortName]string, []byte, error)

+ type Network []*node

+ func NewVirtualNetwork(port int, numNodes int) (Network, error)

+ func (n Network) Start()

+ type NetworkStreamSession struct

+ func (n *NetworkStreamSession) Close()

+ func (n *NetworkStreamSession) Info() view.SessionInfo

+ func (n *NetworkStreamSession) Receive() <-chan *view.Message

+ func (n *NetworkStreamSession) Send(payload []byte) error

+ func (n *NetworkStreamSession) SendError(payload []byte) error

+ type P2PNode struct

+ func NewBootstrapNode(ListenAddress string, keyDispenser PrivateKeyDispenser) (*P2PNode, error)

+ func NewNode(ListenAddress, BootstrapNode string, keyDispenser PrivateKeyDispenser) (*P2PNode, error)

+ func (p *P2PNode) DeleteSessions(sessionID string)

+ func (p *P2PNode) Lookup(peerID string) (peer.AddrInfo, bool)

+ func (p *P2PNode) MasterSession() (view.Session, error)

+ func (p *P2PNode) NewSession(callerViewID string, contextID string, endpoint string, pkid []byte) (view.Session, error)

+ func (p *P2PNode) NewSessionWithID(sessionID, contextID, endpoint string, pkid []byte, caller view.Identity, ...) (view.Session, error)

+ func (p *P2PNode) Start(ctx context.Context)

+ func (p *P2PNode) Stop()

+ type PrivateKeyDispenser interface

+ PrivateKey func() (crypto.PrivKey, error)

+ func GetPrivateKeyDispenser(sp view2.ServiceProvider) PrivateKeyDispenser

+ type PrivateKeyFromCryptoKey struct

+ Key crypto.PrivKey

+ func (p *PrivateKeyFromCryptoKey) PrivateKey() (crypto.PrivKey, error)

+ type PrivateKeyFromFile struct

+ PrivateKeyFile string

+ func (p *PrivateKeyFromFile) PrivateKey() (crypto.PrivKey, error)

+ type Service struct

+ ConfigService ConfigService

+ DefaultIdentity view2.Identity

+ EndpointService EndpointService

+ Node *P2PNode

+ PrivateKeyDispenser PrivateKeyDispenser

+ func NewService(privateKeyDispenser PrivateKeyDispenser, endpointService EndpointService, ...) (*Service, error)

+ func (s *Service) DeleteSessions(sessionID string)

+ func (s *Service) MasterSession() (view2.Session, error)

+ func (s *Service) NewSession(caller string, contextID string, endpoint string, pkid []byte) (view2.Session, error)

+ func (s *Service) NewSessionWithID(sessionID, contextID, endpoint string, pkid []byte, caller view2.Identity, ...) (view2.Session, error)

+ func (s *Service) Start(ctx context.Context)

+ func (s *Service) Stop()

+ type ViewPacket struct

+ Caller string

+ ContextID string

+ Payload []byte

+ SessionID string

+ Status int32

+ func (*ViewPacket) Descriptor() ([]byte, []int)

+ func (*ViewPacket) ProtoMessage()

+ func (x *ViewPacket) GetCaller() string

+ func (x *ViewPacket) GetContextID() string

+ func (x *ViewPacket) GetPayload() []byte

+ func (x *ViewPacket) GetSessionID() string

+ func (x *ViewPacket) GetStatus() int32

+ func (x *ViewPacket) ProtoReflect() protoreflect.Message

+ func (x *ViewPacket) Reset()

+ func (x *ViewPacket) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL