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 DatasetVersionTaskExecutor
- func (e *DatasetVersionTaskExecutor) Migrate(ctx context.Context, task *domain.Task) error
- func (e *DatasetVersionTaskExecutor) PostPublish(ctx context.Context, task *domain.Task) error
- func (e *DatasetVersionTaskExecutor) Publish(ctx context.Context, task *domain.Task) error
- func (e *DatasetVersionTaskExecutor) 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, serviceAuthToken string) *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, serviceAuthToken string) *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 DatasetVersionTaskExecutor ¶ added in v0.24.0
type DatasetVersionTaskExecutor struct {
// contains filtered or unexported fields
}
DatasetVersionTaskExecutor executes migration tasks for dataset versions.
func NewDatasetVersionTaskExecutor ¶ added in v0.24.0
func NewDatasetVersionTaskExecutor(jobService application.JobService, clientList *clients.ClientList, serviceAuthToken string) *DatasetVersionTaskExecutor
NewDatasetVersionTaskExecutor creates a new DatasetVersionTaskExecutor
func (*DatasetVersionTaskExecutor) Migrate ¶ added in v0.24.0
Migrate handles the migration operations for a dataset edition task.
func (*DatasetVersionTaskExecutor) PostPublish ¶ added in v0.24.0
PostPublish handles the post-publish operations for a dataset version 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