config

Documentation

Index

• type KafkaBasic
• type Redis
• type Service
• type Worker
• type Workers

Types

type KafkaBasic

type KafkaBasic struct {
	Brokers     []string `yaml:"brokers" json:"brokers,omitempty"`
	Topic       string   `yaml:"topic" json:"topic,omitempty"`
	Credentials struct {
		Type     string `yaml:"type" json:"type,omitempty"`
		Username string `yaml:"username" json:"username,omitempty"`
		Password string `yaml:"password" json:"password,omitempty"`
	} `yaml:"credentials" json:"credentials,omitempty"`
}

type Redis

type Redis struct {
	Addr     string `yaml:"addr" json:"addr,omitempty"`
	DB       int    `yaml:"db" json:"db,omitempty"`
	Username string `yaml:"username" json:"username,omitempty"`
	Password string `yaml:"password" json:"password,omitempty"`
}

type Service

type Service struct {
	Kafka       KafkaBasic `yaml:"kafka" json:"kafka,omitempty"`
	Redis       Redis      `yaml:"redis" json:"redis,omitempty"`
	EventSource string     `yaml:"event_source" json:"event_source,omitempty"`
}

type Worker

type Worker struct {
	Kafka struct {
		KafkaBasic    `yaml:",inline" json:",inline"`
		ConsumerGroup string `yaml:"consumer_group" json:"consumer_group,omitempty"`
	} `yaml:"kafka" json:"kafka,omitempty"`
	Redis   Redis             `yaml:"redis" json:"redis,omitempty"`
	Options map[string]string `yaml:"options" json:"options,omitempty"`
}

type Workers

type Workers struct {
	Tiup       *Worker `yaml:"tiup,omitempty" json:"tiup,omitempty"`
	FileServer *Worker `yaml:"file_server,omitempty" json:"file_server,omitempty"`
}