config

Documentation

Index

• func StartKvWatch(watchConfig *EtcdKVWatchConfig, wg *sync.WaitGroup)
• type EtcdKVWatchConfig

Functions

func StartKvWatch

func StartKvWatch(watchConfig *EtcdKVWatchConfig, wg *sync.WaitGroup)

启动一个etcd kv watch 通过MergeConfigFunc回调全量更新数据 go StartKvWatch()

Types

type EtcdKVWatchConfig

type EtcdKVWatchConfig struct {
	EtcdAddrss      []string
	DialTimeout     int
	Key             string // "/config/dev/eds"
	MergeConfigFunc func(data string)
	Log             *log.Logger
	Options         *store.Config
}