model

type ConsumeConfig struct {
	//主键ID
	Id int `json:"id" gorm:"primaryKey"`
	//队列名
	Topic string `json:"topic"`
	//通道名
	Channel string `json:"channel"`
	//描述
	Description string `json:"description"`
	//责任人
	Owner string `json:"owner"`
	//积压报警阈值
	MonitorThreshold int `json:"monitorThreshold"`
	//该队列的并发量
	HandleNum int `json:"handleNum"`
	//NSQD最多同时推送多少个消息
	MaxInFlight int `json:"maxInFlight"`
	//失败，超时等情况是否重新入队
	IsRequeue bool `json:"isRequeue"`
	//超时时间
	TimeoutDial time.Duration `json:"timeoutDial"`
	//读超时时间
	TimeoutRead time.Duration `json:"timeoutRead"`
	//写超时时间
	TimeoutWrite time.Duration `json:"timeoutWrite"`
	//是否有效
	Invalid int `json:"invalid"`
	//创建时间
	CreatedAt time.Time `json:"createdAt"`
	//更新时间
	UpdatedAt time.Time `json:"updatedAt"`

	//那些work机器可以消费该队列
	ServerList []ConsumeServerMap `json:"serverList" gorm:"-"`
	//nsq客户端的消费者
	Consumer *nsq.Consumer `json:"-" gorm:"-"`
	// contains filtered or unexported fields
}

type ConsumeServerMap struct {
	Id        int `json:"id" gorm:"primaryKey"`
	Consumeid int `json:"consumeid"`
	Serverid  int `json:"serverid"`
	Weight    int `json:"weight"`
	Invalid   int `json:"invalid"`
	//创建时间
	CreatedAt time.Time `json:"createdAt"`
	//更新时间
	UpdatedAt time.Time `json:"updatedAt"`

	WorkServer WorkServer `json:"workServer" gorm:"-"`
}

type PageResult struct {
	Total  int64       `json:"total"`
	Page   int         `json:"page"`
	Result interface{} `json:"result"`
}

type WorkServer struct {
	Id int `json:"id" gorm:"primaryKey"`
	//地址，IP:PORT
	Addr string `json:"addr"`
	//协议，如HTTP、FastCGI、CBNSQ
	Protocol string `json:"protocol"`
	//扩展字段
	Extra string `json:"extra"`
	//描述
	Description string `json:"description"`
	//责任人
	Owner string `json:"owner"`
	//是否有效
	Invalid int `json:"invalid"`
	//创建时间
	CreatedAt time.Time `json:"createdAt"`
	//更新时间
	UpdatedAt time.Time `json:"updatedAt"`
	// contains filtered or unexported fields
}