xnsq

type NsqNodeConfig struct {
	Host  string `yaml:"Host" json:"Host"`
	Topic string `yaml:"Topic" json:"Topic"`
	IsRun int    `yaml:"IsRun" json:"IsRun"` //0 # 1 停止推送
}

type ProducerClient struct {
	// contains filtered or unexported fields
}

type ProducerConfig map[string]*NsqNodeConfig