Versions in this module Expand all Collapse all v1 v1.9.2 Sep 24, 2021 Changes in this version + func GetTaskLags(cfg *config.Config) (taskLags map[string]int64, err error) v1.5.2 Jul 26, 2022 Changes in this version + func GetTaskStateAndLags(cfg *config.Config) (stateLags map[string]StateLag, err error) + type InstanceAssignment struct + Instance string + TaskLags []TaskLag + TotalLag int64 + type NacosConfManager struct + func (ncm *NacosConfManager) Deregister(ip string, port int) (err error) + func (ncm *NacosConfManager) GetConfig() (conf *config.Config, err error) + func (ncm *NacosConfManager) Init(properties map[string]interface{}) (err error) + func (ncm *NacosConfManager) PublishConfig(conf *config.Config) (err error) + func (ncm *NacosConfManager) Register(ip string, port int) (err error) + func (ncm *NacosConfManager) Run() + func (ncm *NacosConfManager) Stop() + type RemoteConfManager interface + Deregister func(ip string, port int) (err error) + GetConfig func() (conf *config.Config, err error) + Init func(properties map[string]interface{}) error + PublishConfig func(conf *config.Config) (err error) + Register func(ip string, port int) (err error) + Run func() + Stop func() + type StateLag struct + Lag int64 + State string + func GetTaskStateAndLag(cfg *config.Config, taskName string) (stateLag StateLag, err error) + type TaskLag struct + Lag int64 + Task string
Go to main page