controlplanejob

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

type ActivityParams struct {
	fx.In

	DB   *gorm.DB `name:"psql"`
	CHDB *gorm.DB `name:"ch"`
	Cfg  *internal.Config
	L    *zap.Logger
}

type EnsureExecutionRequest struct {
	JobID string `json:"job_id" validate:"required"`
}

type EnsureExecutionResponse struct {
	ExecutionID         string        `json:"execution_id"`
	JobExecutionTimeout time.Duration `json:"job_execution_timeout"`
}

type ExecuteRequest struct {
	JobID string `json:"job_id" validate:"required"`
}

type FinalizeOutcome struct {
	Success bool   `json:"success"`
	Error   string `json:"error,omitempty"`
}

type FinalizeRequest struct {
	JobID       string          `json:"job_id" validate:"required"`
	ExecutionID string          `json:"execution_id" validate:"required"`
	Outcome     FinalizeOutcome `json:"outcome"`
}

type RunJobRequest struct {
	JobID       string `json:"job_id" validate:"required"`
	ExecutionID string `json:"execution_id" validate:"required"`
}

type WorkerConfig struct {
	MaxConcurrentActivityExecutionSize int
	MaxConcurrentActivityTaskPollers   int
	Interceptors                       []interceptor.WorkerInterceptor
	WorkflowPanicPolicy                worker.WorkflowPanicPolicy
}

type Workflows struct{}