cmd

Documentation

Index

• Constants
• type Cmd
  • func NewService(cfg *config.Chain, logConfig *config.LogConfig, nodeId string) *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

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"
)

Types

type Cmd

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

func NewService

func NewService(cfg *config.Chain, logConfig *config.LogConfig, nodeId string) *Cmd

func (*Cmd) ExecBlockTask

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

func (*Cmd) ExecReceiptTask

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

func (*Cmd) ExecTxTask

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

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) HandlerTx

func (c *Cmd) HandlerTx(tx *collect.TxInterface) (*kafka.Message, error)

func (*Cmd) ReadNodeTaskFromKafka

func (c *Cmd) ReadNodeTaskFromKafka(nodeId string, blockChain int, blockCh chan *collect.NodeTask, txCh chan *collect.NodeTask, receiptChan chan *collect.NodeTask, ctx context.Context)

func (*Cmd) Start

func (c *Cmd) Start(ctx context.Context)

func (*Cmd) Stop

func (c *Cmd) Stop()