Versions in this module Expand all Collapse all v0 v0.1.1 Nov 12, 2024 Changes in this version + type NewStreamArgs interface + type NewStreamArgs1 struct + BytesLimit ragep2p.TokenBucketParams + IncomingBufferSize int + MaxMessageLength int + MessagesLimit ragep2p.TokenBucketParams + OutgoingBufferSize int + StreamName string + type PeerGroup interface + Close func() error + NewStream func(remotePeerID string, newStreamArgs NewStreamArgs) (Stream, error) + type PeerGroupFactory interface + NewPeerGroup func(configDigest ocr2types.ConfigDigest, peerIDs []string, ...) (PeerGroup, error) + type Stream interface + Close func() error + ReceiveMessages func() <-chan []byte + SendMessage func(data []byte) v0.0.1 Jul 24, 2024 Changes in this version + const MaxOCRMsgLength + func NewPeer(c PeerConfig) (*concretePeerV2, error) + type BinaryNetworkEndpointLimits struct + BytesCapacityPerOracle int + BytesRatePerOracle float64 + MaxMessageLength int + MessagesCapacityPerOracle int + MessagesRatePerOracle float64 + type EndpointConfigV2 struct + IncomingMessageBufferSize int + OutgoingMessageBufferSize int + type PeerConfig struct + LatencyMetricsServiceConfigs []*rageping.LatencyMetricsServiceConfig + Logger commontypes.Logger + MetricsRegisterer prometheus.Registerer + PrivKey ed25519.PrivateKey + V2AnnounceAddresses []string + V2DeltaDial time.Duration + V2DeltaReconcile time.Duration + V2DiscovererDatabase nettypes.DiscovererDatabase + V2EndpointConfig EndpointConfigV2 + V2ListenAddresses []string
Go to main page