etcd

Documentation

Index

• func Init(addrs string, timeout time.Duration) (err error)
• func WatchConf(key string, newConfCh chan<- []*LogEntry)
• type LogEntry
  • func GetConf(key string) (logEntryConf []*LogEntry, err error)

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 获取配置信息