Documentation
¶
Index ¶
- type DatasetEditionTaskExecutor
- func (e *DatasetEditionTaskExecutor) Migrate(ctx context.Context, task *domain.Task) error
- func (e *DatasetEditionTaskExecutor) PostPublish(ctx context.Context, task *domain.Task) error
- func (e *DatasetEditionTaskExecutor) Publish(ctx context.Context, task *domain.Task) error
- func (e *DatasetEditionTaskExecutor) Revert(ctx context.Context, task *domain.Task) error
- type DatasetSeriesTaskExecutor
- func (e *DatasetSeriesTaskExecutor) Migrate(ctx context.Context, task *domain.Task) error
- func (e *DatasetSeriesTaskExecutor) PostPublish(ctx context.Context, task *domain.Task) error
- func (e *DatasetSeriesTaskExecutor) Publish(ctx context.Context, task *domain.Task) error
- func (e *DatasetSeriesTaskExecutor) Revert(ctx context.Context, task *domain.Task) error
- type JobExecutor
- type StaticDatasetJobExecutor
- func (e *StaticDatasetJobExecutor) Migrate(ctx context.Context, job *domain.Job) error
- func (e *StaticDatasetJobExecutor) PostPublish(ctx context.Context, job *domain.Job) error
- func (e *StaticDatasetJobExecutor) Publish(ctx context.Context, job *domain.Job) error
- func (e *StaticDatasetJobExecutor) Revert(ctx context.Context, job *domain.Job) error
- type TaskExecutor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DatasetEditionTaskExecutor ¶
type DatasetEditionTaskExecutor struct {
// contains filtered or unexported fields
}
DatasetEditionTaskExecutor executes migration tasks for dataset editions.
func NewDatasetEditionTaskExecutor ¶
func NewDatasetEditionTaskExecutor(jobService application.JobService, clientList *clients.ClientList) *DatasetEditionTaskExecutor
NewDatasetEditionTaskExecutor creates a new DatasetEditionTaskExecutor
func (*DatasetEditionTaskExecutor) Migrate ¶
Migrate handles the migration operations for a dataset edition task.
func (*DatasetEditionTaskExecutor) PostPublish ¶
PostPublish handles the post-publish operations for a dataset edition task.
type DatasetSeriesTaskExecutor ¶
type DatasetSeriesTaskExecutor struct {
// contains filtered or unexported fields
}
DatasetSeriesTaskExecutor executes migration tasks for dataset series.
func NewDatasetSeriesTaskExecutor ¶
func NewDatasetSeriesTaskExecutor(jobService application.JobService, clientList *clients.ClientList) *DatasetSeriesTaskExecutor
NewDatasetSeriesTaskExecutor creates a new DatasetSeriesTaskExecutor
func (*DatasetSeriesTaskExecutor) Migrate ¶
Migrate handles the migration operations for a dataset series task.
func (*DatasetSeriesTaskExecutor) PostPublish ¶
PostPublish handles post-publish operations for a dataset series task.
type JobExecutor ¶
type JobExecutor interface {
Migrate(ctx context.Context, job *domain.Job) error
Publish(ctx context.Context, job *domain.Job) error
PostPublish(ctx context.Context, job *domain.Job) error
Revert(ctx context.Context, job *domain.Job) error
}
JobExecutor defines the contract for job migration operations
type StaticDatasetJobExecutor ¶
type StaticDatasetJobExecutor struct {
// contains filtered or unexported fields
}
StaticDatasetJobExecutor executes migration jobs for static datasets.
func NewStaticDatasetJobExecutor ¶
func NewStaticDatasetJobExecutor(jobService application.JobService, clientList *clients.ClientList) *StaticDatasetJobExecutor
NewStaticDatasetJobExecutor creates a new StaticDatasetJobExecutor
func (*StaticDatasetJobExecutor) Migrate ¶
Migrate handles the migration operations for a static dataset job.
func (*StaticDatasetJobExecutor) PostPublish ¶
PostPublish handles the post-publish operations for a static dataset job.
type TaskExecutor ¶
type TaskExecutor interface {
Migrate(ctx context.Context, task *domain.Task) error
Publish(ctx context.Context, task *domain.Task) error
PostPublish(ctx context.Context, task *domain.Task) error
Revert(ctx context.Context, task *domain.Task) error
}
TaskExecutor defines the contract for task migration operations
Source Files
Directories