Documentation
¶
Index ¶
- type ConsulConfig
- type ConsulManager
- func (self *ConsulManager) CheckService(services []*consulapi.AgentService, srvName, addr string) bool
- func (self *ConsulManager) Client(ds ...string) (*ConsulManager, error)
- func (self *ConsulManager) GetAllService(service string) ([]*consulapi.AgentService, error)
- func (self *ConsulManager) GetCacheService(service, tag string, cacheSecond int) ([]*consulapi.ServiceEntry, error)
- func (self *ConsulManager) GetHealthService(service, tag string) ([]*consulapi.ServiceEntry, error)
- func (self *ConsulManager) GetJsonValue(key string, result interface{}) error
- func (self *ConsulManager) GetSlowLog() *zap.Logger
- func (self *ConsulManager) GetTextValue(key string) ([]byte, error)
- func (self *ConsulManager) HealthCheck(w http.ResponseWriter, r *http.Request)
- func (self *ConsulManager) InitConfig(input ...ConsulConfig) (*ConsulManager, error)
- func (self *ConsulManager) RemoveService(serviceIDs ...string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsulConfig ¶
type ConsulConfig struct {
DsName string // 数据源名
Host string // consul host
CheckPort int // 健康监测端口
RpcPort int // RPC调用端口
Protocol string // RPC协议, tcp
Timeout string // 请求超时时间, 3s
Interval string // 健康监测时间, 5s
DestroyAfter string // 销毁服务时间, 600s
CheckPath string // 健康检测path /xxx/check
SlowQuery int64 // 0.不开启筛选 >0开启筛选查询 毫秒
SlowLogPath string // 慢查询写入地址
}
Consulx配置参数
type ConsulManager ¶
type ConsulManager struct {
Host string
Token string
Consulx *consulapi.Client
Config *ConsulConfig
}
func NewConsul ¶
func NewConsul(ds ...string) (*ConsulManager, error)
func (*ConsulManager) CheckService ¶
func (self *ConsulManager) CheckService(services []*consulapi.AgentService, srvName, addr string) bool
func (*ConsulManager) Client ¶
func (self *ConsulManager) Client(ds ...string) (*ConsulManager, error)
func (*ConsulManager) GetAllService ¶
func (self *ConsulManager) GetAllService(service string) ([]*consulapi.AgentService, error)
根据服务名获取可用列表
func (*ConsulManager) GetCacheService ¶
func (self *ConsulManager) GetCacheService(service, tag string, cacheSecond int) ([]*consulapi.ServiceEntry, error)
func (*ConsulManager) GetHealthService ¶
func (self *ConsulManager) GetHealthService(service, tag string) ([]*consulapi.ServiceEntry, error)
func (*ConsulManager) GetJsonValue ¶
func (self *ConsulManager) GetJsonValue(key string, result interface{}) error
通过Consul中心获取指定JSON配置数据
func (*ConsulManager) GetSlowLog ¶
func (self *ConsulManager) GetSlowLog() *zap.Logger
func (*ConsulManager) GetTextValue ¶
func (self *ConsulManager) GetTextValue(key string) ([]byte, error)
func (*ConsulManager) HealthCheck ¶
func (self *ConsulManager) HealthCheck(w http.ResponseWriter, r *http.Request)
接口服务健康检查
func (*ConsulManager) InitConfig ¶
func (self *ConsulManager) InitConfig(input ...ConsulConfig) (*ConsulManager, error)
func (*ConsulManager) RemoveService ¶
func (self *ConsulManager) RemoveService(serviceIDs ...string)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.