Versions in this module Expand all Collapse all v1 v1.4.2 May 30, 2023 v1.4.0 May 30, 2023 Changes in this version + var BytesPool *bytePool + var ErrNodesUnavailable = errors.New("All nodes unvailabale") + var ErrorEmptyBlockBody = errors.New("block is empty") + var ErrorWrongSizeBytes = errors.New("wrong size bytes") + func BroadcastNodeConnInfo(tcpAddress string, data []byte, logger *log.Entry) error + func CheckConfirmation(host string, blockID int64, logger *log.Entry) (hash string) + func GetBlockBodiesChan(ctx context.Context, src io.ReadCloser, blocksCount int64) (<-chan []byte, <-chan error) + func GetBlocksBodies(ctx context.Context, host string, blockID int64, reverseOrder bool) (<-chan []byte, error) + func GetMaxBlockID(host string) (blockID int64, err error) + func HostWithMaxBlock(ctx context.Context, hosts []string) (bestHost string, maxBlockID int64, err error) + func MarshalTxPacket(txes []sqldb.Transaction) ([]byte, error) + func NormalizeHostAddress(address string, defaultPort int64) (string, error) + func SendFullBlockToAll(ctx context.Context, hosts []string, block *sqldb.InfoBlock, ...) error + func SendStopNetwork(addr string, req *network.StopNetworkRequest) error + func SendTransacitionsToAll(ctx context.Context, hosts []string, txes []sqldb.Transaction) error + func UpdateMachineStatus(localAddress, tcpAddress string, logger *log.Entry) ([]byte, error)