|
|
@ -25,20 +25,20 @@ import (
|
|
|
|
type CronTaskCmd struct {
|
|
|
|
type CronTaskCmd struct {
|
|
|
|
*RootCmd
|
|
|
|
*RootCmd
|
|
|
|
ctx context.Context
|
|
|
|
ctx context.Context
|
|
|
|
configMap map[string]StructEnvPrefix
|
|
|
|
configMap map[string]any
|
|
|
|
cronTaskConfig tools.CronTaskConfig
|
|
|
|
cronTaskConfig tools.CronTaskConfig
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func NewCronTaskCmd() *CronTaskCmd {
|
|
|
|
func NewCronTaskCmd() *CronTaskCmd {
|
|
|
|
var cronTaskConfig tools.CronTaskConfig
|
|
|
|
var cronTaskConfig tools.CronTaskConfig
|
|
|
|
ret := &CronTaskCmd{cronTaskConfig: cronTaskConfig}
|
|
|
|
ret := &CronTaskCmd{cronTaskConfig: cronTaskConfig}
|
|
|
|
ret.configMap = map[string]StructEnvPrefix{
|
|
|
|
ret.configMap = map[string]any{
|
|
|
|
OpenIMCronTaskCfgFileName: {EnvPrefix: cornTaskEnvPrefix, ConfigStruct: &cronTaskConfig.CronTask},
|
|
|
|
OpenIMCronTaskCfgFileName: &cronTaskConfig.CronTask,
|
|
|
|
RedisConfigFileName: {EnvPrefix: redisEnvPrefix, ConfigStruct: &cronTaskConfig.RedisConfig},
|
|
|
|
RedisConfigFileName: &cronTaskConfig.RedisConfig,
|
|
|
|
MongodbConfigFileName: {EnvPrefix: mongodbEnvPrefix, ConfigStruct: &cronTaskConfig.MongodbConfig},
|
|
|
|
MongodbConfigFileName: &cronTaskConfig.MongodbConfig,
|
|
|
|
ZookeeperConfigFileName: {EnvPrefix: zoopkeeperEnvPrefix, ConfigStruct: &cronTaskConfig.ZookeeperConfig},
|
|
|
|
ZookeeperConfigFileName: &cronTaskConfig.ZookeeperConfig,
|
|
|
|
ShareFileName: {EnvPrefix: shareEnvPrefix, ConfigStruct: &cronTaskConfig.Share},
|
|
|
|
ShareFileName: &cronTaskConfig.Share,
|
|
|
|
KafkaConfigFileName: {EnvPrefix: kafkaEnvPrefix, ConfigStruct: &cronTaskConfig.KafkaConfig},
|
|
|
|
KafkaConfigFileName: &cronTaskConfig.KafkaConfig,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ret.RootCmd = NewRootCmd(program.GetProcessName(), WithConfigMap(ret.configMap))
|
|
|
|
ret.RootCmd = NewRootCmd(program.GetProcessName(), WithConfigMap(ret.configMap))
|
|
|
|
ret.ctx = context.WithValue(context.Background(), "version", config.Version)
|
|
|
|
ret.ctx = context.WithValue(context.Background(), "version", config.Version)
|
|
|
|