node

Documentation

Index

• Constants
• func Mine(ctx context.Context, pb PendingBlock) (database.Block, error)
• type AddPeerRes
• type BalancesRes
• type ErrRes
• type Node
  • func New(dataDir string, ip string, port uint64, acc database.Account, ...) *Node
  • func (n *Node) AddPeer(peer PeerNode)
  • func (n *Node) AddPendingTX(tx database.Tx, fromPeer PeerNode) error
  • func (n *Node) IsKnownPeer(peer PeerNode) bool
  • func (n *Node) LatestBlockHash() database.Hash
  • func (n *Node) RemovePeer(peer PeerNode)
  • func (n *Node) Run(ctx context.Context) error
• type PeerNode
  • func NewPeerNode(ip string, port uint64, isBootstrap bool, acc database.Account, connected bool) PeerNode
  • func (pn PeerNode) TcpAddress() string
• type PendingBlock
  • func NewPendingBlock(parent database.Hash, number uint64, miner database.Account, txs []database.Tx) PendingBlock
• type StatusRes
• type SyncRes
• type TxAddReq
• type TxAddRes

Constants

const DefaultHTTPort = 8080

const DefaultIP = "127.0.0.1"

const DefaultMiner = ""

Functions

func Mine

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

Types

type AddPeerRes

type AddPeerRes struct {
	Success bool   `json:"success"`
	Error   string `json:"error"`
}

type BalancesRes

type BalancesRes struct {
	Hash     database.Hash             `json:"block_hash"`
	Balances map[database.Account]uint `json:"balances"`
}

type ErrRes

type ErrRes struct {
	Error string `json:"error"`
}

type Node

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

func New

func New(dataDir string, ip string, port uint64, acc database.Account, bootstrap PeerNode) *Node

func (*Node) AddPeer

func (n *Node) AddPeer(peer PeerNode)

func (*Node) AddPendingTX

func (n *Node) AddPendingTX(tx database.Tx, fromPeer PeerNode) error

func (*Node) IsKnownPeer

func (n *Node) IsKnownPeer(peer PeerNode) bool

func (*Node) LatestBlockHash

func (n *Node) LatestBlockHash() database.Hash

func (*Node) RemovePeer

func (n *Node) RemovePeer(peer PeerNode)

func (*Node) Run

func (n *Node) Run(ctx context.Context) error

type PeerNode

type PeerNode struct {
	IP          string           `json:"ip"`
	Port        uint64           `json:"port"`
	IsBootstrap bool             `json:"is_bootstrap"`
	Account     database.Account `json:"account"`
	// contains filtered or unexported fields
}

func NewPeerNode

func NewPeerNode(ip string, port uint64, isBootstrap bool, acc database.Account, connected bool) PeerNode

func (PeerNode) TcpAddress

func (pn PeerNode) TcpAddress() string

type PendingBlock

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

func NewPendingBlock

func NewPendingBlock(parent database.Hash, number uint64, miner database.Account, txs []database.Tx) PendingBlock

type StatusRes

type StatusRes struct {
	Hash       database.Hash       `json:"block_hash"`
	Number     uint64              `json:"block_number"`
	KnownPeers map[string]PeerNode `json:"peers_known"`
	PendingTXs []database.Tx       `json:"pending_txs"`
}

type SyncRes

type SyncRes struct {
	Blocks []database.Block `json:"blocks"`
}

type TxAddReq

type TxAddReq struct {
	From  string `json:"from"`
	To    string `json:"to"`
	Value uint   `json:"value"`
	Data  string `json:"data"`
}

type TxAddRes

type TxAddRes struct {
	Success bool `json:"success"`
}