task

Documentation

Index

• func GetBlockChainService(c *config.Chain, db *config.TaskDb, sourceDb *config.SourceDb, ...) service.BlockChainInterface
• type Cmd
  • func NewService(c *config.Chain, taskDb *config.TaskDb, sourceDb *config.SourceDb, ...) *Cmd
  • func (c *Cmd) ExecBlockTask(blockCh chan *service.NodeTask, kf chan []*kafka.Message)
  • func (c *Cmd) ExecReceiptTask(receiptChan chan *service.NodeTask, kf chan []*kafka.Message)
  • func (c *Cmd) ExecTxTask(txCh chan *service.NodeTask, kf chan []*kafka.Message)
  • func (c *Cmd) HandlerBlock(block *service.Block) (*kafka.Message, error)
  • func (c *Cmd) HandlerKafkaRespMessage(kafkaRespCh chan []*kafka.Message)
  • func (c *Cmd) HandlerKafkaRespMessageEx(kafkaRespCh chan []*kafka.Message)
  • func (c *Cmd) HandlerReceipt(receipt *service.Receipt) (*kafka.Message, error)
  • func (c *Cmd) HandlerTx(tx *service.Tx) (*kafka.Message, error)
  • func (c *Cmd) Start()
  • func (c *Cmd) Stop()

Functions

func GetBlockChainService

func GetBlockChainService(c *config.Chain, db *config.TaskDb, sourceDb *config.SourceDb, logConfig *config.LogConfig) service.BlockChainInterface

Types

type Cmd

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

func NewService

func NewService(c *config.Chain, taskDb *config.TaskDb, sourceDb *config.SourceDb, logConfig *config.LogConfig) *Cmd

func (*Cmd) ExecBlockTask

func (c *Cmd) ExecBlockTask(blockCh chan *service.NodeTask, kf chan []*kafka.Message)

func (*Cmd) ExecReceiptTask

func (c *Cmd) ExecReceiptTask(receiptChan chan *service.NodeTask, kf chan []*kafka.Message)

func (*Cmd) ExecTxTask

func (c *Cmd) ExecTxTask(txCh chan *service.NodeTask, kf chan []*kafka.Message)

func (*Cmd) HandlerBlock

func (c *Cmd) HandlerBlock(block *service.Block) (*kafka.Message, error)

func (*Cmd) HandlerKafkaRespMessage

func (c *Cmd) HandlerKafkaRespMessage(kafkaRespCh chan []*kafka.Message)

func (*Cmd) HandlerKafkaRespMessageEx

func (c *Cmd) HandlerKafkaRespMessageEx(kafkaRespCh chan []*kafka.Message)

func (*Cmd) HandlerReceipt

func (c *Cmd) HandlerReceipt(receipt *service.Receipt) (*kafka.Message, error)

func (*Cmd) HandlerTx

func (c *Cmd) HandlerTx(tx *service.Tx) (*kafka.Message, error)

func (*Cmd) Start

func (c *Cmd) Start()

func (*Cmd) Stop

func (c *Cmd) Stop()