Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Logger logger.Config `koanf:"logger"` Telemetry telemetry.Config `koanf:"telemetry"` Output cmq.Config `koanf:"output"` Input Input `koanf:"input"` Stream Stream `koanf:"stream"` Channel string `koanf:"channel"` Topics []string `koanf:"topics"` }
Config holds all configurations.
type Input ¶
type Input struct { Type `koanf:"type"` Group string NATS cmq.Config `koanf:"nats"` Streaming streaming.Config `koanf:"streaming"` }
Input specifies the source of the data which is pushed into jectstream.
Click to show internal directories.
Click to hide internal directories.