producers

func Produce ¶

func Produce(w *kafka.Writer, message []byte, topic string)

func ProduceLedger ¶

func ProduceLedger(w *kafka.Writer, message []byte)

func ProduceTransaction ¶

func ProduceTransaction(w *kafka.Writer, message []byte)

* Submits transaction object to Kafka

func ProduceTransactions ¶

func ProduceTransactions(w *kafka.Writer, message []byte)

* Produce multiple transactions from a given ledger_index. * * Verifies structure of `ledger` websocket command, iterates over `transactions` * slice, and calls ProduceTransaction for each transaction object. * * These transaction objects have slightly different structure, as compared to * transactions returned via `tx` and `account_tx` commands.

func ProduceValidation ¶

func ProduceValidation(w *kafka.Writer, message []byte)

func RunProducers ¶

func RunProducers()