Documentation
¶
Index ¶
- type Datastore
- func (ds *Datastore) ClaimJob(ctx context.Context, pendingState, activeState domain.JobState) (*domain.Job, error)
- func (ds *Datastore) ClaimTask(ctx context.Context, pendingState, activeState domain.TaskState) (*domain.Task, error)
- func (ds *Datastore) CountEventsByJobID(ctx context.Context, jobID string) (int, error)
- func (ds *Datastore) CountTasksByJobID(ctx context.Context, jobID string) (int, error)
- func (ds *Datastore) CreateEvent(ctx context.Context, event *domain.Event) error
- func (ds *Datastore) CreateJob(ctx context.Context, job *domain.Job) error
- func (ds *Datastore) CreateTask(ctx context.Context, task *domain.Task) error
- func (ds *Datastore) GetJob(ctx context.Context, jobID string) (*domain.Job, error)
- func (ds *Datastore) GetJobEvents(ctx context.Context, jobID string, limit, offset int) ([]*domain.Event, int, error)
- func (ds *Datastore) GetJobTasks(ctx context.Context, jobID string, limit, offset int) ([]*domain.Task, int, error)
- func (ds *Datastore) GetJobs(ctx context.Context, states []domain.JobState, limit, offset int) ([]*domain.Job, int, error)
- func (ds *Datastore) GetJobsByConfigAndState(ctx context.Context, jc *domain.JobConfig, states []domain.JobState, ...) ([]*domain.Job, error)
- func (ds *Datastore) GetTask(ctx context.Context, taskID string) (*domain.Task, error)
- func (ds *Datastore) UpdateJob(ctx context.Context, job *domain.Job) error
- func (ds *Datastore) UpdateTask(ctx context.Context, task *domain.Task) error
- type MongoDB
- type Storer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Datastore ¶
type Datastore struct {
Backend Storer
}
Datastore provides a datastore.Storer interface used to store, retrieve, remove or update bundles
func (*Datastore) ClaimJob ¶ added in v0.15.0
func (ds *Datastore) ClaimJob(ctx context.Context, pendingState, activeState domain.JobState) (*domain.Job, error)
ClaimJob claims a pending job for processing.
func (*Datastore) ClaimTask ¶ added in v0.15.0
func (ds *Datastore) ClaimTask(ctx context.Context, pendingState, activeState domain.TaskState) (*domain.Task, error)
ClaimTask claims a pending task for processing.
func (*Datastore) CountEventsByJobID ¶ added in v0.12.0
CountEventsByJobID returns the total count of events for a job.
func (*Datastore) CountTasksByJobID ¶ added in v0.11.0
CountTasksByJobID returns the total count of tasks for a job.
func (*Datastore) CreateEvent ¶ added in v0.12.0
CreateEvent creates a new migration event.
func (*Datastore) CreateTask ¶ added in v0.12.0
CreateTask creates a new migration task.
func (*Datastore) GetJobEvents ¶ added in v0.12.0
func (ds *Datastore) GetJobEvents(ctx context.Context, jobID string, limit, offset int) ([]*domain.Event, int, error)
GetJobEvents retrieves a list of migration events for a job with pagination.
func (*Datastore) GetJobTasks ¶ added in v0.11.0
func (ds *Datastore) GetJobTasks(ctx context.Context, jobID string, limit, offset int) ([]*domain.Task, int, error)
GetJobTasks retrieves a list of migration tasks for a job with pagination.
func (*Datastore) GetJobs ¶ added in v0.10.0
func (ds *Datastore) GetJobs(ctx context.Context, states []domain.JobState, limit, offset int) ([]*domain.Job, int, error)
GetJobs retrieves a list of migration jobs with pagination.
func (*Datastore) GetJobsByConfigAndState ¶ added in v0.7.0
func (ds *Datastore) GetJobsByConfigAndState(ctx context.Context, jc *domain.JobConfig, states []domain.JobState, limit, offset int) ([]*domain.Job, error)
GetJobsByConfigAndState retrieves jobs based on the provided job configuration and states.
type MongoDB ¶
type MongoDB interface {
Close(context.Context) error
Checker(context.Context, *healthcheck.CheckState) error
// contains filtered or unexported methods
}
MongoDB represents all the required methods from mongoDB
Source Files
Directories