conf

package
v0.0.0-...-61d2b90 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 17, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadConfFile

func LoadConfFile() (err error)

LoadConfFile load confile.yaml

Types

type Conf

type Conf struct {
	Kafka KafkaConf `yaml:"kafka"`
}

func Get

func Get() *Conf

type KafkaConf

type KafkaConf struct {
	Host    string   `yaml:"host"`
	Addrs   []string `yaml:"addrs"`
	PartNum int      `yaml:"partNum"` // 分区数
	Group   struct {
		Delay string `yaml:"delay"`
	} `yaml:"group"`
	Topic struct {
		Delay5s  string `yaml:"delay5s"`
		Delay1m  string `yaml:"delay1m"`
		Delay10m string `yaml:"delay10m"`
		Delay1h  string `yaml:"delay1h"`
	} `yaml:"topic"`
}

Jump to

Keyboard shortcuts

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