types

type Message struct {
	Sender  PeerID
	Payload []byte
}

type Peer interface {
	services.Service
	ID() PeerID
	UpdateConnections(peers map[PeerID]StreamConfig) error
	Send(peerID PeerID, msg []byte) error
	Receive() <-chan Message
}

type PeerID = ragetypes.PeerID

type PeerWrapper interface {
	services.Service
	GetPeer() Peer
}

type Signer interface {
	Sign(data []byte) ([]byte, error)
}

type StreamConfig struct {
	IncomingMessageBufferSize int
	OutgoingMessageBufferSize int
	MaxMessageLenBytes        int
	MessageRateLimiter        ragep2p.TokenBucketParams
	BytesRateLimiter          ragep2p.TokenBucketParams
}