Versions in this module Expand all Collapse all v1 v1.0.0 Jan 6, 2023 Changes in this version + type KafkaClient struct + Topic string + func NewKafkaClient(addrs []string, topic string) *KafkaClient + func (kc *KafkaClient) Send(hash []byte, tx *watcher.Transaction) error + type KafkaMsg struct + Data *watcher.Transaction + Source interface{} + Topic string + func (j *KafkaMsg) MarshalJSON() ([]byte, error) + func (j *KafkaMsg) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (j *KafkaMsg) UnmarshalJSON(input []byte) error + func (j *KafkaMsg) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type Sender interface + Send func(hash []byte, tx *watcher.Transaction) error + type Watcher struct + func NewWatcher(clientCtx context.CLIContext, log log.Logger, sender Sender) *Watcher + func (w *Watcher) Start()
Go to main page