producers

Documentation

Index

• func Produce(w *kafka.Writer, message []byte, topic string)
• func ProduceLedger(w *kafka.Writer, message []byte)
• func ProduceTransaction(w *kafka.Writer, message []byte)
• func ProduceTransactions(w *kafka.Writer, message []byte)
• func ProduceValidation(w *kafka.Writer, message []byte)
• func RunProducers()

Functions

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