node

type BlockHashRequestMessage struct {
	Height int32
}

type BlockHashResponseMessage struct {
	Hash          common.Hash
	CurrentHeight int32
}

type BlockRequestMessage struct {
	Height int32
}

type BlockResponseMessage struct {
	Block *types.Block
}

type ChainInfoRequestMessage struct {
}

type ChainInfoResponseMessage struct {
	To            string
	Version       uint32
	CurrentHeight int32
}

type DecodedMessage struct {
	From net.Addr
	Data any
}

type Message struct {
	Header MessageType
	Data   []byte
}

type MessageType byte

type NetAddr string

type Node struct {
	TCPTransport *TCPTransport

	NodeOpts
	// contains filtered or unexported fields
}

type NodeOpts struct {
	APIListenAddr string
	SeedNodes     []string
	ListenAddr    string
	TCPTransport  *TCPTransport
	Name          string
	Logger        log.Logger
	RPCDecodeFunc RPCDecodeFunc
	RPCProcessor  RPCProcessor
	BlockTime     time.Duration
	PrivateKey    *types.PrivateKey
}

type RPC struct {
	From    net.Addr //string
	Payload io.Reader
}

type RPCDecodeFunc func(RPC) (*DecodedMessage, error)

type RPCProcessor interface {
	HandleMessage(*DecodedMessage) error
}

type TCPPeer struct {
	Outgoing bool
	// contains filtered or unexported fields
}

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

type Transport interface {
	Consume() <-chan RPC
	Connect(Transport) error
	SendMessage(net.Addr, []byte) error
	Broadcast([]byte) error
	Addr() net.Addr
}

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

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