p2p

Documentation

Index

• Variables
• type AccountsP2P
  • func (a AccountsP2P) Marshal() []byte
• type BlockP2P
  • func (b BlockP2P) MapToBlock() (*blockchain.Block, error)
  • func (b BlockP2P) Marshal() []byte
• type BlockchainForest
  • func NewBlockchainForest(bcLocal *blockchain.Blockchain) *BlockchainForest
  • func (b *BlockchainForest) AddBlock(blockP2p BlockP2P)
  • func (b *BlockchainForest) GetBlock(peerId []byte, blockId []byte, blockOnly bool) BlockP2P
• type ChallengeWordP2P
  • func (a ChallengeWordP2P) Marshal() []byte
• type MappingsP2P
  • func (a MappingsP2P) Marshal() []byte
• type P2P
  • func NewP2P(bc *blockchain.Blockchain, bindHost string, bindPort uint16, ...) *P2P
  • func (p *P2P) BroadcastObject(object noise.Serializable)
  • func (p *P2P) GetPeers() []byte
  • func (p *P2P) SyncAccountsFromPeers()
  • func (p *P2P) SyncMappingsFromPeers()
  • func (p *P2P) SyncPeerBlockchains()
• type RequestP2P
  • func (a RequestP2P) Marshal() []byte

Variables

var DefaultPort = 6091

var PingIntervalInMs = 3000

Types

type AccountsP2P

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

AccountsP2P represents all the accounts from a peer

func (AccountsP2P) Marshal

func (a AccountsP2P) Marshal() []byte

Marshal serializes AccountsP2P

type BlockP2P

type BlockP2P struct {
	PeerId            []byte
	Timestamp         int64
	PrevBlockHash     []byte
	Height            uint64
	Hash              []byte
	IsTip             bool
	TotalTransactions int
	Transactions      []blockchain.Transaction
}

BlockP2P represents a block from a peer

func (BlockP2P) MapToBlock

func (b BlockP2P) MapToBlock() (*blockchain.Block, error)

MapToBlock verified each transaction in the BlockP2P on wire and convert it to blockchain.Block

func (BlockP2P) Marshal

func (b BlockP2P) Marshal() []byte

Marshal serializes BlockP2P

type BlockchainForest

type BlockchainForest struct {
	Local *blockchain.Blockchain
	Peers map[string]*blockchain.Blockchain
}

BlockchainForest defines the local and peer chains

func NewBlockchainForest

func NewBlockchainForest(bcLocal *blockchain.Blockchain) *BlockchainForest

NewBlockchainForest initializes the peer blockchains by reading existing dbs from peerBlockchainDir which will be created should not exist

func (*BlockchainForest) AddBlock

func (b *BlockchainForest) AddBlock(blockP2p BlockP2P)

AddBlock persist the broadcasted or requested block from a peer to local peer blockchain db and index it

func (*BlockchainForest) GetBlock

func (b *BlockchainForest) GetBlock(peerId []byte, blockId []byte, blockOnly bool) BlockP2P

GetBlock returns a local or peer block as requested

type ChallengeWordP2P

type ChallengeWordP2P struct {
	ChallengeWord string
	Address       string
}

ChallengeWordP2P represents a challengeWord cache item from a peer

func (ChallengeWordP2P) Marshal

func (a ChallengeWordP2P) Marshal() []byte

Marshal serializes ChallengeWordP2P

type MappingsP2P

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

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

func (MappingsP2P) Marshal

func (a MappingsP2P) Marshal() []byte

Marshal serializes MappingsP2P

type P2P

type P2P struct {
	Node                *noise.Node
	BlockchainForest    *BlockchainForest
	ChallengeWordsCache *cache.Cache

	Accounts map[string]blockchain.Account // used by http
	// contains filtered or unexported fields
}

P2P is the main object to handle networking-related messages

func NewP2P

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

NewP2P initializes the P2P node with messages and handlers

func (*P2P) BroadcastObject

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

BroadcastObject sends a serializable object to all the known peers

func (*P2P) GetPeers

func (p *P2P) GetPeers() []byte

GetPeers returns currently know peers in json format

func (*P2P) SyncAccountsFromPeers

func (p *P2P) SyncAccountsFromPeers()

SyncAccountsFromPeers sends rpc to peers to sync the accounts

func (*P2P) SyncMappingsFromPeers

func (p *P2P) SyncMappingsFromPeers()

SyncMappingsFromPeers sends rpc to peers to sync the mappings

func (*P2P) SyncPeerBlockchains

func (p *P2P) SyncPeerBlockchains()

SyncPeerBlockchains sends rpc to all known peers to sync the peer blockchains to local

type RequestP2P

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

RequestP2P represents common p2p request body

func (RequestP2P) Marshal

func (a RequestP2P) Marshal() []byte

Marshal serializes RequestP2P