job

Documentation

Index

• type CleanConfigFileHistoryJobConfig
• type CleanDeletedClientsJobConfig
• type CleanDeletedInstancesJobConfig
• type DeleteEmptyServiceJobConfig
• type DeleteUnHealthyInstanceJobConfig
• type JobConfig
• type MaintainJobs
  • func NewMaintainJobs(namingServer service.DiscoverServer, cacheMgn *cache.CacheManager, ...) *MaintainJobs
  • func (mj *MaintainJobs) StartMaintianJobs(configs []JobConfig) error
  • func (mj *MaintainJobs) StopMaintainJobs()

Types

type CleanConfigFileHistoryJobConfig

type CleanConfigFileHistoryJobConfig struct {
	RetentionDays time.Duration `mapstructure:"retentionDays"`
	BatchSize     uint64        `mapstructure:"batchSize"`
}

type CleanDeletedClientsJobConfig

type CleanDeletedClientsJobConfig struct {
	ClientCleanTimeout time.Duration `mapstructure:"clientCleanTimeout"`
}

type CleanDeletedInstancesJobConfig

type CleanDeletedInstancesJobConfig struct {
	InstanceCleanTimeout time.Duration `mapstructure:"instanceCleanTimeout"`
}

type DeleteEmptyServiceJobConfig

type DeleteEmptyServiceJobConfig struct {
	ServiceDeleteTimeout time.Duration `mapstructure:"serviceDeleteTimeout"`
}

type DeleteUnHealthyInstanceJobConfig

type DeleteUnHealthyInstanceJobConfig struct {
	InstanceDeleteTimeout time.Duration `mapstructure:"instanceDeleteTimeout"`
}

type JobConfig

type JobConfig struct {
	Name   string                 `yaml:"name"`
	Enable bool                   `yaml:"enable"`
	Option map[string]interface{} `yaml:"option"`
}

JobcConfig maintain job configuration

type MaintainJobs

type MaintainJobs struct {
	// contains filtered or unexported fields
}

MaintainJobs

func NewMaintainJobs

func NewMaintainJobs(namingServer service.DiscoverServer, cacheMgn *cache.CacheManager,
	storage store.Store) *MaintainJobs

NewMaintainJobs

func (*MaintainJobs) StartMaintianJobs

func (mj *MaintainJobs) StartMaintianJobs(configs []JobConfig) error

StartMaintainJobs

func (*MaintainJobs) StopMaintainJobs

func (mj *MaintainJobs) StopMaintainJobs()

StopMaintainJobs