network

type BlocksMessage struct {
	Blocks []*core.Block
}

type DecodedMessage struct {
	From net.Addr
	Data any
}

type GetBlocksMessage struct {
	From uint32
	// If To is 0 the maximum blocks will be returned.
	To uint32
}

type GetStatusMessage struct{}

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

type Message struct {
	Header MessageType
	Data   []byte
}

type MessageType byte

type NetAddr string

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

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

type RPCProcessor interface {
	ProcessMessage(*DecodedMessage) error
}

type Server struct {
	TCPTransport *TCPTransport

	ServerOpts
	// contains filtered or unexported fields
}

type ServerOpts struct {
	APIListenAddr string
	SeedNodes     []string
	ListenAddr    string
	TCPTransport  *TCPTransport
	ID            string
	Logger        log.Logger
	RPCDecodeFunc RPCDecodeFunc
	RPCProcessor  RPCProcessor
	BlockTime     time.Duration
	PrivateKey    *crypto.PrivateKey
}

type StatusMessage struct {
	// the id of the server
	ID            string
	Version       uint32
	CurrentHeight uint32
}

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
}