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)deprecated
- func IndexTransaction(m kafka.Message)deprecated
- func IndexValidation(m kafka.Message)deprecated
- func ModifyAmount(tx map[string]interface{}, field string, network xrpl.Network) error
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
Generate Elasticsearch index name based on documentType and ledger_index
func GetLedgerIndex ¶
func Index ¶
func Index(req esapi.IndexRequest)
func IndexLedger
deprecated
func IndexLedger(m kafka.Message)
Deprecated: This function does not support new IndexTemplate based indexing
func IndexTransaction
deprecated
func IndexTransaction(m kafka.Message)
Deprecated: This function does not support new IndexTemplate based indexing
func IndexValidation
deprecated
func IndexValidation(m kafka.Message)
Deprecated: This function does not support new IndexTemplate based indexing
func ModifyAmount ¶
func ModifyTransaction ¶
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)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.