indexer

Documentation

Index

• func BulkIndexLedger(ch <-chan kafka.Message)
• func BulkIndexTransaction(ch <-chan kafka.Message)
• func BulkIndexValidation(ch <-chan kafka.Message)
• func GetIndexName(documentType string, ledger_index int) string
• func GetLedgerIndex(message []byte) (int, error)
• func Index(req esapi.IndexRequest)
• func IndexLedger(m kafka.Message)
• func IndexTransaction(m kafka.Message)
• func IndexValidation(m kafka.Message)
• func ModifyTransaction(tx map[string]interface{}) (map[string]interface{}, error)
• func NewBulkIndexClient(label string) (esutil.BulkIndexer, error)
• func PrintMessage(m kafka.Message)
• func Test(m kafka.Message)

Functions

func BulkIndexLedger

func BulkIndexLedger(ch <-chan kafka.Message)

func BulkIndexTransaction

func BulkIndexTransaction(ch <-chan kafka.Message)

func BulkIndexValidation

func BulkIndexValidation(ch <-chan kafka.Message)

func GetIndexName

func GetIndexName(documentType string, ledger_index int) string

Generate Elasticsearch index name based on documentType and ledger_index

func GetLedgerIndex

func GetLedgerIndex(message []byte) (int, error)

func Index

func Index(req esapi.IndexRequest)

func IndexLedger

func IndexLedger(m kafka.Message)

Deprecated: This function does not support new IndexTemplate based indexing

func IndexTransaction

func IndexTransaction(m kafka.Message)

Deprecated: This function does not support new IndexTemplate based indexing

func IndexValidation

func IndexValidation(m kafka.Message)

Deprecated: This function does not support new IndexTemplate based indexing

func ModifyTransaction

func ModifyTransaction(tx map[string]interface{}) (map[string]interface{}, error)

Modify transacion object to normalize Amount-like and other fields.

func NewBulkIndexClient

func NewBulkIndexClient(label string) (esutil.BulkIndexer, error)

Create a new Elasticsearch bulk index client

func PrintMessage

func PrintMessage(m kafka.Message)

func Test

func Test(m kafka.Message)