config

package

v0.0.7 Latest Latest Go to latest Published: Apr 5, 2024 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/etf1/kafka-message-scheduler

Links

Open Source Insights

Documentation ¶

Index ¶

func BootstrapServers() string
func ConfigurationFile() string
func GraylogServer() string
func GroupID() string
func HistoryTopic() string
func LogLevel() log.Level
func MetricsAddr() string
func ScheduleGraceInterval() int
func SchedulesTopics() []string
func ServerAddr() string
func SessionTimeout() int
func SinceDelta() int
type File
- func ReadFile(filePath string) (File, error)
- func (f *File) GenerateConsumerConfiguration() confluent.ConfigMap
- func (f *File) GenerateProducerConfiguration() confluent.ConfigMap

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BootstrapServers ¶

func BootstrapServers() string

func ConfigurationFile ¶ added in v0.0.5

func ConfigurationFile() string

func GraylogServer ¶

func GraylogServer() string

func GroupID ¶

func GroupID() string

func HistoryTopic ¶

func HistoryTopic() string

func LogLevel ¶

func LogLevel() log.Level

func MetricsAddr ¶ added in v0.0.4

func MetricsAddr() string

func ScheduleGraceInterval ¶ added in v0.0.6

func ScheduleGraceInterval() int

func SchedulesTopics ¶

func SchedulesTopics() []string

func ServerAddr ¶ added in v0.0.4

func ServerAddr() string

func SessionTimeout ¶

func SessionTimeout() int

func SinceDelta ¶

func SinceDelta() int

Types ¶

type File ¶ added in v0.0.5

type File struct {
	KafkaCommonConfiguration   confluent.ConfigMap `yaml:"kafka.common.configuration,omitempty"`
	KafkaProducerConfiguration confluent.ConfigMap `yaml:"kafka.producer.configuration,omitempty"`
	KafkaConsumerConfiguration confluent.ConfigMap `yaml:"kafka.consumer.configuration,omitempty"`
}

func ReadFile ¶ added in v0.0.5

func ReadFile(filePath string) (File, error)

func (*File) GenerateConsumerConfiguration ¶ added in v0.0.5

func (f *File) GenerateConsumerConfiguration() confluent.ConfigMap

func (*File) GenerateProducerConfiguration ¶ added in v0.0.5

func (f *File) GenerateProducerConfiguration() confluent.ConfigMap

Source Files ¶

View all Source files

config.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL