Versions in this module Expand all Collapse all v0 v0.1.1 May 14, 2023 Changes in this version + type KafkaClient struct + Topic string + func NewKafkaClient(addrs []string, topic string) *KafkaClient + func (kc *KafkaClient) SendPending(hash []byte, tx *PendingTx) error + func (kc *KafkaClient) SendRmPending(hash []byte, tx *RmPendingTx) error + type PendingMsg struct + Data *PendingTx + Source interface{} + Topic string + type PendingTx struct + From string + Gas hexutil.Uint64 + GasPrice *hexutil.Big + Hash common.Hash + Input string + Nonce hexutil.Uint64 + To *common.Address + Value *hexutil.Big + type RmPendingMsg struct + Data *RmPendingTx + Source interface{} + Topic string + type RmPendingTx struct + Delete bool + From string + Hash string + Nonce string + Reason int + type Sender interface + SendPending func(hash []byte, tx *PendingTx) error + SendRmPending func(hash []byte, tx *RmPendingTx) error + type Watcher struct + func NewWatcher(clientCtx context.CLIContext, log log.Logger, sender Sender) *Watcher + func (w *Watcher) Start()
Go to main page