mongo

package

v1.28.0 Latest Latest Go to latest Published: Oct 10, 2024 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var CreatedJob = models.Job{ID: "34534543543"}

CreatedJob represents a job returned by AddJob

View Source

var InternalError = errors.New("DataStore internal error")

This section is empty.

type DataStorer struct {
	NotFound      bool
	InternalError bool
	IsLocked      bool
	HasBeenLocked bool
}

func (ds *DataStorer) AcquireInstanceLock(_ context.Context, _ string) (lockID string, err error)

func (ds *DataStorer) AddInstance(_ context.Context, _ string) (string, error)

func (ds *DataStorer) AddJob(_ context.Context, _ *models.Job) (*models.Job, error)

func (ds *DataStorer) AddUploadedFile(_ context.Context, _ string, _ *models.UploadedFile) error

func (ds *DataStorer) Checker(_ context.Context, _ *healthcheck.CheckState) error

func (ds *DataStorer) Close(_ context.Context) error

func (ds *DataStorer) GetJob(_ context.Context, _ string) (*models.Job, error)

func (ds *DataStorer) GetJobs(_ context.Context, _ []string, _ int, _ int) (*models.JobResults, error)

func (ds *DataStorer) UnlockInstance(_ context.Context, lockID string)

func (ds *DataStorer) UpdateJob(_ context.Context, _ string, _ *models.Job) error

func (ds *DataStorer) UpdateJobState(_ context.Context, _ string, _ string) error

func (ds *DataStorer) UpdateProcessedInstance(_ context.Context, _ string, _ []models.ProcessedInstances) (err error)