node

Documentation

Index

• Constants
• func GeneratePrivateKey(seed int64) crypto.PrivKey
• func MakePeer(dest string) (peer.ID, multiaddr.Multiaddr)
• func Mine(ctx context.Context, pb PendingBlock) (state.Block, error)
• type Node
  • func NewNode(name string, datadir string, miner string, ip string, port uint64, tls bool) *Node
  • func (n *Node) AddPendingTX(tx state.SignedTx) error
  • func (n *Node) Join(ctx context.Context, topicName string, bufSize int, ...) error
  • func (n *Node) Run(ctx context.Context, ip string, port int, rpcHost string, rpcPort uint64, ...) error
• type PendingBlock
  • func NewPendingBlock(parent state.Hash, number uint64, miner common.Address, txs []state.SignedTx) PendingBlock

Constants

const (
	DiscoveryServiceTag            = "mercury-service-tag"
	DiscoveryServiceTag_PendingTxs = "pending_txs"
	DiscoveryServiceTag_Blocks     = "blocks"
	DiscoveryServiceTag_Announce   = "announce"
)

Functions

func GeneratePrivateKey

func GeneratePrivateKey(seed int64) crypto.PrivKey

GeneratePrivateKey - creates a private key with the given seed

func MakePeer

func MakePeer(dest string) (peer.ID, multiaddr.Multiaddr)

MakePeer takes a fully-encapsulated address and converts it to a peer ID / Multiaddress pair

func Mine

func Mine(ctx context.Context, pb PendingBlock) (state.Block, error)

Types

type Node

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

func NewNode

func NewNode(name string, datadir string, miner string, ip string, port uint64, tls bool) *Node

func (*Node) AddPendingTX

func (n *Node) AddPendingTX(tx state.SignedTx) error

* Add a pending transaction to the node's pending transactions array

func (*Node) Join

func (n *Node) Join(ctx context.Context, topicName string,
	bufSize int, onMessage core.MessageHandler,
	msgChan chan core.MessageTransport) error

func (*Node) Run

func (n *Node) Run(ctx context.Context, ip string, port int, rpcHost string, rpcPort uint64, peer string, name string) error

type PendingBlock

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

PendingBlock represents a block before it has been mined

func NewPendingBlock

func NewPendingBlock(parent state.Hash, number uint64, miner common.Address, txs []state.SignedTx) PendingBlock