config

Documentation

Index

• func EnvEsFingerprint() string
• func EnvEsFlushInterval() int
• func EnvEsNamespace() string
• func EnvEsPassword() string
• func EnvEsURL() string
• func EnvEsUsername() string
• func EnvKafkaBootstrapServer() string
• func EnvKafkaGroupId() string
• func EnvKafkaTopicNamespace() string
• func EnvLoad(filenames ...string)
• func EnvLogLevel() string
• func EnvLogType() string
• func EnvServerHost() string
• func EnvServerPort() string
• func EnvXrplWebsocketFullHistoryURL() string
• func EnvXrplWebsocketURL() string
• func TopicConsensus() string
• func TopicDefault() string
• func TopicLedgers() string
• func TopicManifests() string
• func TopicPathFind() string
• func TopicPeerStatus() string
• func TopicServer() string
• func TopicTransactions() string
• func TopicValidations() string

Functions

func EnvEsFingerprint

func EnvEsFingerprint() string

func EnvEsFlushInterval

func EnvEsFlushInterval() int

func EnvEsNamespace

func EnvEsNamespace() string

func EnvEsPassword

func EnvEsPassword() string

func EnvEsURL

func EnvEsURL() string

func EnvEsUsername

func EnvEsUsername() string

func EnvKafkaBootstrapServer

func EnvKafkaBootstrapServer() string

* Kafka settings

func EnvKafkaGroupId

func EnvKafkaGroupId() string

func EnvKafkaTopicNamespace

func EnvKafkaTopicNamespace() string

func EnvLoad

func EnvLoad(filenames ...string)

func EnvLogLevel

func EnvLogLevel() string

Get default log level

func EnvLogType

func EnvLogType() string

Get default log type

func EnvServerHost

func EnvServerHost() string

Get HTTP server hostname

func EnvServerPort

func EnvServerPort() string

Get HTTP server port

func EnvXrplWebsocketFullHistoryURL

func EnvXrplWebsocketFullHistoryURL() string

func EnvXrplWebsocketURL

func EnvXrplWebsocketURL() string

* XRPL protocol (compatible) server settings

func TopicConsensus

func TopicConsensus() string

Kafka topic for streaming xrpl.StreamTypeConsensus messages

func TopicDefault

func TopicDefault() string

Kafka topic for streaming messages that do not match any StreamType*

func TopicLedgers

func TopicLedgers() string

Kafka topic for streaming xrpl.StreamTypeLedger messages

func TopicManifests

func TopicManifests() string

Kafka topic for streaming xrpl.StreamTypeManifests messages

func TopicPathFind

func TopicPathFind() string

Kafka topic for streaming xrpl.StreamTypePathFind messages

func TopicPeerStatus

func TopicPeerStatus() string

Kafka topic for streaming xrpl.StreamTypePeerStatus messages

func TopicServer

func TopicServer() string

Kafka topic for streaming xrpl.StreamTypeServer messages

func TopicTransactions

func TopicTransactions() string

Kafka topic for streaming xrpl.StreamTypeTransaction messages

func TopicValidations

func TopicValidations() string

Kafka topic for streaming xrpl.StreamTypeValidations messages