Documentation
¶
Index ¶
- Variables
- func CloseAll()
- func CloseEsClient()
- func CloseReaders()
- func CloseWriter()
- func CloseXrplClient()
- func GetEsClient() *elasticsearch.Client
- func NewConsensusReader()
- func NewDefaultReader()
- func NewEsClient()
- func NewLedgerReader()
- func NewManifestReader()
- func NewPathFindReader()
- func NewPeerStatusReader()
- func NewReaderConfig() kafka.ReaderConfig
- func NewReaders()
- func NewServerReader()
- func NewTransactionReader()
- func NewValidationReader()
- func NewWriter()
- func NewXrplClient()
- func NewXrplClientWithURL(URL string)
- func SubscribeStreams()
- func UnsubscribeStreams()
Constants ¶
This section is empty.
Variables ¶
var EsClient *elasticsearch.Client
var KafkaReaderConsensus *kafka.Reader
var KafkaReaderDefault *kafka.Reader
var KafkaReaderLedger *kafka.Reader
var KafkaReaderManifest *kafka.Reader
var KafkaReaderPathFind *kafka.Reader
var KafkaReaderPeerStatus *kafka.Reader
var KafkaReaderServer *kafka.Reader
var KafkaReaderTransaction *kafka.Reader
var KafkaReaderValidation *kafka.Reader
var KafkaWriter *kafka.Writer
var XrplClient *xrpl.Client
Functions ¶
func CloseEsClient ¶
func CloseEsClient()
func CloseReaders ¶
func CloseReaders()
func CloseWriter ¶
func CloseWriter()
func CloseXrplClient ¶
func CloseXrplClient()
func GetEsClient ¶
func GetEsClient() *elasticsearch.Client
func NewConsensusReader ¶
func NewConsensusReader()
Create a new Kafka Reader connection to $namespace-platform-consensus topic
func NewDefaultReader ¶
func NewDefaultReader()
Create a new Kafka Reader connection to $namespace-platform-default topic
func NewEsClient ¶
func NewEsClient()
func NewLedgerReader ¶
func NewLedgerReader()
Create a new Kafka Reader connection to $namespace-platform-ledger topic
func NewManifestReader ¶
func NewManifestReader()
Create a new Kafka Reader connection to $namespace-platform-manifest topic
func NewPathFindReader ¶
func NewPathFindReader()
Create a new Kafka Reader connection to $namespace-platform-pathfind topic
func NewPeerStatusReader ¶
func NewPeerStatusReader()
Create a new Kafka Reader connection to $namespace-platform-peerstatus topic
func NewReaderConfig ¶
func NewReaderConfig() kafka.ReaderConfig
Returns Kafka reader config with default settings applied
func NewReaders ¶
func NewReaders()
func NewServerReader ¶
func NewServerReader()
Create a new Kafka Reader connection to $namespace-platform-server topic
func NewTransactionReader ¶
func NewTransactionReader()
Create a new Kafka Reader connection to $namespace-platform-transaction topic
func NewValidationReader ¶
func NewValidationReader()
Create a new Kafka Reader connection to $namespace-platform-validation topic
func NewWriter ¶
func NewWriter()
Common Kafka writer for the application. Every message must specify the Topic where it must be written to.
func NewXrplClient ¶
func NewXrplClient()
func NewXrplClientWithURL ¶
func NewXrplClientWithURL(URL string)
func SubscribeStreams ¶
func SubscribeStreams()
* TLDR - Do not subscribe to xrpl.StreamTypeTransactions * * XRPL `transaction` stream messages are incompatible with rippled's native * transaction format. Therefore, this service does not process transactions * streamed on `xrpl.StreamTypeTransactions` stream. Instead, we listen to the * ledger stream, fetch transactions from rippled, and add those transactions to * the Kafka topic.
func UnsubscribeStreams ¶
func UnsubscribeStreams()
* Unsubscribe XRPL streams (usually before disconnecting)
Types ¶
This section is empty.
Source Files