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
	MW   metrics.Writer

	BlobSvc          blobstore.Service
	StatusActivities *statusactivities.Activities
}

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 {
	Status app.RunnerJobExecutionStatus `json:"status"`
	Error  string                       `json:"error,omitempty"`
}

type FinalizeResponse struct {
	Status app.RunnerJobExecutionStatus `json:"status"`
}

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

type Workflows struct{}