p2p

package

v0.0.0-...-5cda5f8 Latest Latest Go to latest Published: Aug 16, 2023 License: MIT, MIT Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mantlenetworkio/mantle

Documentation ¶

Index ¶

Constants
Variables
func ReadStreamWithBuffer(stream network.Stream) ([]byte, error)
func WriteStreamWithBuffer(msg []byte, stream network.Stream) error
type AddrList
type Communication
- func NewCommunication(bootstrapPeers []maddr.Multiaddr, port int, externalIP string, ...) (*Communication, error)
type Config
type Message
type MessageIDSubscriber
- func NewMessageIDSubscriber() *MessageIDSubscriber
type StreamMgr
- func NewStreamMgr() *StreamMgr
- func (sm *StreamMgr) AddStream(msgID string, stream network.Stream)
- func (sm *StreamMgr) ReleaseStream(msgID string)

Constants ¶

View Source

const (
	LengthHeader        = 4 // LengthHeader represent how many bytes we used as header
	TimeoutReadPayload  = time.Second * 10
	TimeoutWritePayload = time.Second * 10
	MaxPayload          = 20000000 // 20M
)

View Source

const (
	// TimeoutConnecting maximum time for wait for peers to connect
	TimeoutConnecting = time.Second * 20
)

Variables ¶

View Source

var ApplyDeadline = true

View Source

var TSSProtocolID protocol.ID = "/p2p/tss"

TSSProtocolID protocol id used for tss

Functions ¶

func ReadStreamWithBuffer ¶

func ReadStreamWithBuffer(stream network.Stream) ([]byte, error)

ReadStreamWithBuffer read data from the given stream

func WriteStreamWithBuffer ¶

func WriteStreamWithBuffer(msg []byte, stream network.Stream) error

WriteStreamWithBuffer write the message to stream

Types ¶

type AddrList ¶

type AddrList []maddr.Multiaddr

func (*AddrList) Set ¶

func (al *AddrList) Set(value string) error

func (*AddrList) String ¶

func (al *AddrList) String() string

func (*AddrList) Type ¶

func (al *AddrList) Type() string

type Communication ¶

type Communication struct {
	BroadcastMsgChan chan *messages.BroadcastMsgChan
	// contains filtered or unexported fields
}

func NewCommunication ¶

func NewCommunication(bootstrapPeers []maddr.Multiaddr, port int, externalIP string, waitFullConnected bool, store types.TssMemberStore) (*Communication, error)

func (*Communication) Broadcast ¶

func (c *Communication) Broadcast(peers []peer.ID, msg []byte, msgID string, needHandleResponse bool)

Broadcast message to Peers

func (*Communication) CancelSubscribe ¶

func (c *Communication) CancelSubscribe(topic messages.TSSMessageTpe, msgID string)

func (*Communication) ExportPeerAddress ¶

func (c *Communication) ExportPeerAddress() map[peer.ID]AddrList

func (*Communication) GetHost ¶

func (c *Communication) GetHost() host.Host

GetHost return the host

func (*Communication) GetLocalPeerID ¶

func (c *Communication) GetLocalPeerID() string

GetLocalPeerID from p2p host

func (*Communication) HandleResponse ¶

func (c *Communication) HandleResponse(stream network.Stream, remotePeer peer.ID) error

func (*Communication) ProcessBroadcast ¶

func (c *Communication) ProcessBroadcast()

func (*Communication) ReleaseStream ¶

func (c *Communication) ReleaseStream(msgID string)

func (*Communication) SetSubscribe ¶

func (c *Communication) SetSubscribe(topic messages.TSSMessageTpe, msgID string, channel chan *Message)

func (*Communication) Start ¶

func (c *Communication) Start(priKeyBytes []byte) error

Start will start the communication

func (*Communication) Stop ¶

func (c *Communication) Stop() error

Stop communication

func (*Communication) VerifyPeerId ¶

func (c *Communication) VerifyPeerId(peerId string) bool

type Config ¶

type Config struct {
	RendezvousString string
	Port             int
	BootstrapPeers   []string
	ExternalIP       string
}

type Message ¶

type Message struct {
	PeerID  peer.ID
	Payload []byte
}

type MessageIDSubscriber ¶

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

func NewMessageIDSubscriber ¶

func NewMessageIDSubscriber() *MessageIDSubscriber

func (*MessageIDSubscriber) GetSubscriber ¶

func (ms *MessageIDSubscriber) GetSubscriber(msgID string) chan *Message

GetSubscribers return a subscriber of given message id

func (*MessageIDSubscriber) IsEmpty ¶

func (ms *MessageIDSubscriber) IsEmpty() bool

IsEmpty check whether there is subscribers

func (ms *MessageIDSubscriber) Subscribe(msgID string, channel chan *Message)

Subscribe a message id

func (*MessageIDSubscriber) UnSubscribe ¶

func (ms *MessageIDSubscriber) UnSubscribe(msgID string)

UnSubscribe a messageid

type StreamMgr ¶

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

func NewStreamMgr ¶

func NewStreamMgr() *StreamMgr

func (*StreamMgr) AddStream ¶

func (sm *StreamMgr) AddStream(msgID string, stream network.Stream)

func (*StreamMgr) ReleaseStream ¶

func (sm *StreamMgr) ReleaseStream(msgID string)

Source Files ¶

View all Source files

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

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func ReadStreamWithBuffer ¶

func WriteStreamWithBuffer ¶

Types ¶

type AddrList ¶

func (*AddrList) Set ¶

func (*AddrList) String ¶

func (*AddrList) Type ¶

type Communication ¶

func NewCommunication ¶

func (*Communication) Broadcast ¶

func (*Communication) CancelSubscribe ¶

func (*Communication) ExportPeerAddress ¶

func (*Communication) GetHost ¶

func (*Communication) GetLocalPeerID ¶

func (*Communication) HandleResponse ¶

func (*Communication) ProcessBroadcast ¶

func (*Communication) ReleaseStream ¶

func (*Communication) SetSubscribe ¶

func (*Communication) Start ¶

func (*Communication) Stop ¶

func (*Communication) VerifyPeerId ¶

type Config ¶

type Message ¶

type MessageIDSubscriber ¶

func NewMessageIDSubscriber ¶

func (*MessageIDSubscriber) GetSubscriber ¶

func (*MessageIDSubscriber) IsEmpty ¶

func (*MessageIDSubscriber) Subscribe ¶

func (*MessageIDSubscriber) UnSubscribe ¶

type StreamMgr ¶

func NewStreamMgr ¶

func (*StreamMgr) AddStream ¶

func (*StreamMgr) ReleaseStream ¶

Source Files ¶