Versions in this module Expand all Collapse all v0 v0.5.3 Jan 9, 2024 Changes in this version type Config + Retry *Retry + type Retry struct + Contract int64 + ErrTx int64 + NodeTask int64 v0.5.2 Dec 6, 2023 v0.5.1 Oct 8, 2023 Changes in this version type LogConfig + LogLevel int v0.5.0 Aug 10, 2023 Changes in this version + type BlockTask struct + FromCluster []*FromCluster + Kafka *Kafka + func (b *BlockTask) CopyBlockTask() BlockTask + type Chain struct + BlockChainCode int + BlockChainName string + BlockTask *BlockTask + Kafka *Kafka + PullReceipt bool + PullTx bool + ReceiptTask *ReceiptTask + Redis *Redis + TaskKafka *Kafka + TxTask *TxTask + func (c *Chain) CopyChain() Chain + type Config struct + Chains []*Chain + KeyPath string + LogConfig *LogConfig + func LoadConfig(path string) Config + type FromCluster struct + ErrorCount int64 + Host string + Key string + Port int + Weight int64 + func (f *FromCluster) CopyFromCluster() FromCluster + type Kafka struct + Group string + Host string + Partition int + Partitions []int64 + Port int + StartOffset int64 + Topic string + func (k *Kafka) CopyKafka() Kafka + type LogConfig struct + Delay int64 + Path string + type ReceiptTask struct + FromCluster []*FromCluster + Kafka *Kafka + func (b *ReceiptTask) CopyReceiptTask() ReceiptTask + type Redis struct + Addr string + DB int + Port int64 + type TaskDb struct + Addr string + DbName string + Password string + Port int + Table string + User string + type TxTask struct + FromCluster []*FromCluster + Kafka *Kafka + func (b *TxTask) CopyTxTask() TxTask