Documentation
¶
Index ¶
- Constants
- type Cmd
- func (c *Cmd) ExecBlockTask(blockCh chan *collect.NodeTask, kf chan []*kafka.Message)
- func (c *Cmd) ExecReceiptTask(receiptChan chan *collect.NodeTask, kf chan []*kafka.Message)
- func (c *Cmd) ExecTxTask(txCh chan *collect.NodeTask, kf chan []*kafka.Message)
- func (c *Cmd) HandlerBlock(block *collect.BlockInterface) (*kafka.Message, error)
- func (c *Cmd) HandlerKafkaRespMessage(msList []*kafka.Message)
- func (c *Cmd) HandlerReceipt(receipt *collect.ReceiptInterface) (*kafka.Message, error)
- func (c *Cmd) HandlerTx(tx *collect.TxInterface) (*kafka.Message, error)
- func (c *Cmd) ReadNodeTaskFromKafka(nodeId string, blockChain int, blockCh chan *collect.NodeTask, ...)
- func (c *Cmd) Start(ctx context.Context)
- func (c *Cmd) Stop()
Constants ¶
View Source
const ( KeyBlock = "%v_block_%v" KeyBlockById = "%v_blockId_%v" KeyTx = "%v_tx_%v" KeyTxById = "%v_txId_%v" KeyReceipt = "%v_receipt_%v" KeyReceiptById = "%v_receiptId_%v" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cmd ¶
type Cmd struct {
// contains filtered or unexported fields
}
func NewService ¶
func (*Cmd) ExecBlockTask ¶
func (*Cmd) ExecReceiptTask ¶
func (*Cmd) ExecTxTask ¶
func (*Cmd) HandlerBlock ¶
func (c *Cmd) HandlerBlock(block *collect.BlockInterface) (*kafka.Message, error)
func (*Cmd) HandlerKafkaRespMessage ¶
func (c *Cmd) HandlerKafkaRespMessage(msList []*kafka.Message)
func (*Cmd) HandlerReceipt ¶
func (c *Cmd) HandlerReceipt(receipt *collect.ReceiptInterface) (*kafka.Message, error)
func (*Cmd) ReadNodeTaskFromKafka ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.