network

Dec 22, 2022

Changes in this version

+ type AmountRequest struct

+ Address *string

+ func (amountRequest *AmountRequest) IsInvalid() bool

+ type AmountResponse struct

+ Amount uint64

+ type BlockResponse struct

+ PreviousHash [32]byte

+ RegisteredAddresses []string

+ Timestamp int64

+ Transactions []*TransactionResponse

+ type IpFinder interface

+ DialTimeout func(network, address string, timeout time.Duration) (net.Conn, error)

+ LookupIP func(ip string) ([]net.IP, error)

+ type TargetRequest struct

+ Ip *string

+ Port *uint16

+ type TransactionRequest struct

+ Fee *uint64

+ RecipientAddress *string

+ SenderAddress *string

+ SenderPublicKey *string

+ Signature *string

+ Timestamp *int64

+ Value *uint64

+ func (transactionRequest *TransactionRequest) IsInvalid() bool

+ type TransactionResponse struct

+ Fee uint64

+ RecipientAddress string

+ SenderAddress string

+ SenderPublicKey string

+ Signature string

+ Timestamp int64

+ Value uint64

Oct 31, 2022

Changes in this version

+ type Client interface

+ Send func(topic string, req p2p.Data) (res p2p.Data, err error)

+ type ClientFactory interface

+ CreateClient func(ip string, port uint16, target string) (Client, error)

Oct 28, 2022

Changes in this version

+ const DefaultPort

+ const GetBlocksRequest

+ const GetTransactionsRequest

+ const MineRequest

+ const ParticlesCount

+ const StartMiningRequest

+ const StopMiningRequest

+ type Blockchain interface

+ AddBlock func(blockResponse *neighborhood.BlockResponse)

+ Blocks func() []*neighborhood.BlockResponse

+ CalculateTotalAmount func(currentTimestamp int64, blockchainAddress string) uint64

+ StartVerification func()

+ Verify func()

+ type Host struct

+ func NewHost(server Server, blockchain Blockchain, pool TransactionsPool, ...) *Host

+ func (host *Host) AddTransactions(request *neighborhood.TransactionRequest)

+ func (host *Host) Amount(request *neighborhood.AmountRequest) (res p2p.Data)

+ func (host *Host) GetBlocks() (res p2p.Data)

+ func (host *Host) GetTransactions() (res p2p.Data)

+ func (host *Host) PostTargets(request []neighborhood.TargetRequest)

+ func (host *Host) Run() error

+ type Neighbor struct

+ func NewNeighbor(target *Target, senderFactory SenderFactory, logger *log.Logger) (*Neighbor, error)

+ func (neighbor *Neighbor) AddTransaction(request neighborhood.TransactionRequest) (err error)

+ func (neighbor *Neighbor) GetAmount(request neighborhood.AmountRequest) (amountResponse *neighborhood.AmountResponse, err error)

+ func (neighbor *Neighbor) GetBlocks() (blockResponses []*neighborhood.BlockResponse, err error)

+ func (neighbor *Neighbor) GetTransactions() (transactionResponses []neighborhood.TransactionResponse, err error)

+ func (neighbor *Neighbor) Ip() string

+ func (neighbor *Neighbor) Mine() (err error)

+ func (neighbor *Neighbor) Port() uint16

+ func (neighbor *Neighbor) SendTargets(request []neighborhood.TargetRequest) (err error)

+ func (neighbor *Neighbor) StartMining() (err error)

+ func (neighbor *Neighbor) StopMining() (err error)

+ func (neighbor *Neighbor) Target() string

+ type Sender interface

+ Send func(topic string, req p2p.Data) (res p2p.Data, err error)

+ type SenderFactory interface

+ CreateSender func(ip string, port uint16, target string) (Sender, error)

+ type Server interface

+ Serve func() (err error)

+ SetHandle func(topic string, handler p2p.Handler)

+ type Synchronizer struct

+ func NewSynchronizer(hostPort uint16, time clock.Time, senderFactory SenderFactory, ...) (synchronizer *Synchronizer, err error)

+ func (synchronizer *Synchronizer) AddTargets(targetRequests []neighborhood.TargetRequest)

+ func (synchronizer *Synchronizer) Neighbors() []neighborhood.Neighbor

+ func (synchronizer *Synchronizer) StartSynchronization()

+ func (synchronizer *Synchronizer) Synchronize()

+ func (synchronizer *Synchronizer) Wait()

+ type Target struct

+ func NewTarget(ip string, port uint16) *Target

+ func (target *Target) Ip() string

+ func (target *Target) Port() uint16

+ func (target *Target) Value() string

+ type TransactionsPool interface

+ AddTransaction func(transactionRequest *neighborhood.TransactionRequest, blockchain Blockchain, ...)

+ Transactions func() []*neighborhood.TransactionResponse

+ type Validator interface

+ StartValidation func()

+ StopValidation func()

+ Validate func()