etcd

package
v0.0.0-...-826a30d Latest Latest
Warning

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

Go to latest
Published: Jan 20, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init

func Init(addrs string, timeout time.Duration) (err error)

Init 初始化函数

func WatchConf

func WatchConf(key string, newConfCh chan<- []*LogEntry)

WatchConf 用于监视key的变化

Types

type LogEntry

type LogEntry struct {
	Path  string `json:"path"`  // 日志存放的路径
	Topic string `json:"topic"` // 日志要发往Kafka中的哪个Topic
}

LogEntry 需要收集的日志的配置信息

func GetConf

func GetConf(key string) (logEntryConf []*LogEntry, err error)

GetConf 获取配置信息

Jump to

Keyboard shortcuts

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