Versions in this module Expand all Collapse all v2 v2.4.0 Jul 9, 2021 v2.2.0 Feb 9, 2021 Changes in this version + const LogicalInitialType + const PhysicalInitialType + type DataPatching struct + DockerImage string + QueryPreprocessing QueryPreprocessing + type HealthCheck struct + Interval int64 + MaxRetries int + type LogicalInitial struct + func NewLogicalInitialJob(cfg config.JobConfig, global *dblabCfg.Global, cloneManager pool.FSManager) (*LogicalInitial, error) + func (s *LogicalInitial) Name() string + func (s *LogicalInitial) Reload(cfg map[string]interface{}) (err error) + func (s *LogicalInitial) Run(ctx context.Context) error + type LogicalOptions struct + Configs map[string]string + DataPatching DataPatching + PreprocessingScript string + Schedule Scheduler + type PhysicalInitial struct + func NewPhysicalInitialJob(cfg config.JobConfig, global *dblabCfg.Global, cloneManager pool.FSManager) (*PhysicalInitial, error) + func (p *PhysicalInitial) Name() string + func (p *PhysicalInitial) Reload(cfg map[string]interface{}) (err error) + func (p *PhysicalInitial) Run(ctx context.Context) (err error) + type PhysicalOptions struct + Configs map[string]string + Envs map[string]string + PreprocessingScript string + Promotion Promotion + Scheduler *Scheduler + SkipStartSnapshot bool + Sysctls map[string]string + type Promotion struct + Configs map[string]string + DockerImage string + Enabled bool + HealthCheck HealthCheck + QueryPreprocessing QueryPreprocessing + Recovery map[string]string + type QueryPreprocessing struct + MaxParallelWorkers int + QueryPath string + type ScheduleSpec struct + Limit int + Timetable string + type Scheduler struct + Retention ScheduleSpec + Snapshot ScheduleSpec
Go to main page