config

type ClusterConfig struct {
	Self       string                   `toml:"self"`
	Connection *ClusterConnectionConfig `toml:"connection"`
	Nodes      []*ClusterNodeConfig     `toml:"nodes"`
	Failover   *ClusterFailoverConfig   `toml:"failover"`
}

type ClusterConnectionConfig struct {
	DialTimeout       Duration `toml:"dial_timeout"`
	MaxDelay          Duration `toml:"max_delay"`
	BaseDelay         Duration `toml:"base_delay"`
	Factor            float64  `toml:"factor"`
	Jitter            float64  `toml:"jitter"`
	DisableReqTimeout bool     `toml:"disable_request_timeout"`
	ReqWaitAfter      Duration `toml:"request_wait_after"`
}

type ClusterFailoverConfig struct {
	Enabled       bool     `toml:"enabled"`
	Heartbeat     Duration `toml:"heartbeat"`
	VoteAfter     int      `toml:"vote_after"`
	NodeFailAfter int      `toml:"node_fail_after"`
}

type ClusterNodeConfig struct {
	Name    string `toml:"name"`
	Address string `toml:"address"`
}

type Config struct {
	WsCnf        *WebsocketConfig    `toml:"websocket"`
	ClusterCnf   *ClusterConfig      `toml:"cluster"`
	KafkaCnf     []*KafkaConfig      `toml:"kafkas"`
	PluginsCnf   []*PluginConfig     `toml:"plugins"`
	RouteCnf     *RouteConfig        `toml:"route""`
	RouteHttpCnf *RouteHttpConfig    `toml:"routehttp"`
	SchedulerCnf *SchedulerConfig    `toml:"scheduler"`
	LimitCnf     *LimitConfig        `toml:"limit"`
	LoginMPCnf   *MethodPathConfig   `toml:"login"`
	WhiteList    []*MethodPathConfig `toml:"whiteList"`
}

type Duration struct {
	time.Duration
}

type KafkaConfig struct {
	Brokers   []string `toml:"brokers"`
	Topic     string   `toml:"topic"`
	Offset    int64    `toml:"offset"`
	GroupID   string   `toml:"groupId"`
	Partition int      `toml:"partition"`
	MinBytes  int      `toml:"minBytes"`
	MaxBytes  int      `toml:"maxBytes"`
	MaxWait   Duration `toml:"maxWait"`
}

type LimitConfig struct {
	//最大请求数
	MaxNum int `toml:"maxNum"`
	//每个bucket每秒钟请求个数
	MaxRate int `toml:"maxRate"`
	//每个bucket可溢出请求个数
	MaxBurst int `toml:"maxBurst"`
}

type MethodPathConfig struct {
	Resource string `toml:"resource"`
	Version  string `toml:"version"`
	Action   string `toml:"action"`
}

type PluginConfig struct {
	Enabled    bool   `toml:"enabled"`
	Name       string `toml:"name"`
	ServerAddr string `toml:"server_addr"`
}

type RouteConfig struct {
	//dolphin维护的grpc client的心跳监测周期
	HeartBeat Duration `toml:"heartBeat"`
	//grpc client 回收周期
	Recycle Duration `toml:"recycle"`
	//grpc client 不正常请求个数阙值，超过个数后，在下次回收周期到来后grpc client会被移除
	Threshold int16 `toml:"threshold"`
	//grpc client 请求timeout
	Timeout Duration `toml:"timeout"`
}

type RouteHttpConfig struct {
	Address string `toml:"address"`
}

type SchedulerConfig struct {
	Address string `toml:"address"`
}

type WebsocketConfig struct {
	//监听端口号
	Listen string `toml:"listen"`
	//读取缓冲区大小设置
	ReadBufSize int `toml:"read_buf_size"`
	//写缓冲区大小设置
	WriteBufSize int `toml:"write_buf_size"`
	//tls配置,证书路径等
	Tls *WsTlsConfig `toml:"tls"`
	//写数据timeout
	WriteWait Duration `toml:"write_time_wait"`
	//读数据timeout
	ReadWait Duration `toml:"read_time_wait"`
	//空闲会话timeout
	IdleSessionTimeout Duration `toml:"idle_session_timeout"`
	//写数据个数缓冲区限制
	SessionQueueSize int `toml:"session_queue_size"`
	//写数据个数缓冲区消费等待时间
	QueueOutTimeout Duration `toml:"queue_out_timeout"`
	//sess.guid 盐
	IDSalt string `toml:"id_salt"`
}

type WsAutoCertConfig struct {
	CertCache string   `toml:"cert_cache"`
	Email     string   `toml:"email"`
	Domains   []string `toml:"domains"`
}

type WsTlsConfig struct {
	Enabled      bool              `toml:"enabled"`
	HTTPRedirect string            `toml:"http_redirect"`
	CertFile     string            `toml:"cert_file"`
	KeyFile      string            `toml:"key_file"`
	Autocert     *WsAutoCertConfig `toml:"autocert"`
}