Versions in this module Expand all Collapse all v0 v0.5.3 Jan 9, 2024 v0.5.2 Dec 6, 2023 v0.5.1 Oct 8, 2023 Changes in this version type StoreTaskInterface + ToKafkaMessage func(list []*NodeTask) ([]*kafka.Message, error) v0.5.0 Aug 10, 2023 Changes in this version + const DayFormat + const TimeFormat + type BlockChainInterface interface + CreateNodeTask func(nodeId string, blockChain int64, number string) (*NodeTask, error) + GetLatestBlockNumber func() (int64, error) + type BlockNumber struct + ChainCode int64 + Id int64 + LatestNumber int64 + LogTime time.Time + RecentNumber int64 + type NodeTask struct + BlockChain int64 + BlockHash string + BlockNumber string + CreateTime time.Time + Id int64 + LogTime time.Time + NodeId string + TaskStatus int + TaskType int + TxHash string + type Process interface + Start func(ctx context.Context) + type StoreTaskInterface interface + AddNodeTask func(list []*NodeTask) ([]*kafka.Message, error) + GetAndDelNodeId func(blockChainCode int64) ([]string, error) + GetNodeId func(blockChainCode int64) ([]string, error) + GetRecentNumber func(blockCode int64) (int64, int64, error) + UpdateLastNumber func(blockChainCode int64, latestNumber int64) error + UpdateRecentNumber func(blockChainCode int64, recentNumber int64) error
Go to main page