p2p

package

v0.0.6 Latest Latest Go to latest Published: Apr 14, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

View Source

var DefaultPort = 6091

View Source

var P2PPrivateKeyKey = "p2pPrivKey"

This section is empty.

type AccountsP2P struct {
	Accounts map[string]blockchain.Account
}

AccountsP2P represents all the accounts from a peer

func (a AccountsP2P) Marshal() []byte

Marshal serializes AccountsP2P

type MappingsP2P struct {
	Mappings map[string]blockchain.DocumentMapping
}

MappingsP2P represents all the collection mappings (schemas) from a peer

func (a MappingsP2P) Marshal() []byte

Marshal serializes MappingsP2P

type P2P struct {
	Node *noise.Node
	// contains filtered or unexported fields
}

P2P is the main object to handle networking-related messages

func NewP2P(bc *blockchain.Blockchain, bindHost string, bindPort uint16, advertiseAddress string, connectionAddresses ...string) *P2P

NewP2P initializes the P2P node with messages and handlers

func (p *P2P) BroadcastObject(object noise.Serializable)

BroadcastObject sends a serializable object to all the known peers

func (p *P2P) SyncAccountsFromPeers()

SyncAccountsFromPeers sends rpc to peers to sync the accounts

func (p *P2P) SyncMappingsFromPeers()

SyncMappingsFromPeers sends rpc to peers to sync the mappings

type RequestP2P struct {
	RequestType       string
	RequestParameters map[string]string
}

RequestP2P represents common p2p request body

func (a RequestP2P) Marshal() []byte

Marshal serializes RequestP2P