mongo

Documentation

Index

• Variables
• type DataStorer
  • func (ds *DataStorer) AddInstance(jobID string) (string, error)
  • func (ds *DataStorer) AddJob(importJob *models.Job) (*models.Job, error)
  • func (ds *DataStorer) AddUploadedFile(jobID string, message *models.UploadedFile) error
  • func (m *DataStorer) Checker(ctx context.Context, state *healthcheck.CheckState) error
  • func (m *DataStorer) Close(ctx context.Context) error
  • func (ds *DataStorer) GetJob(jobID string) (*models.Job, error)
  • func (ds *DataStorer) GetJobs(ctx context.Context, filter []string, offset int, limit int) (*models.JobResults, error)
  • func (ds *DataStorer) UpdateJob(string, *models.Job) error
  • func (ds *DataStorer) UpdateJobState(string, string) error

Variables

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

CreatedJob represents a job returned by AddJob

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

Types

type DataStorer

type DataStorer struct {
	NotFound      bool
	InternalError bool
}

func (*DataStorer) AddInstance

func (ds *DataStorer) AddInstance(jobID string) (string, error)

func (*DataStorer) AddJob

func (ds *DataStorer) AddJob(importJob *models.Job) (*models.Job, error)

func (*DataStorer) AddUploadedFile

func (ds *DataStorer) AddUploadedFile(jobID string, message *models.UploadedFile) error

func (*DataStorer) Checker

func (m *DataStorer) Checker(ctx context.Context, state *healthcheck.CheckState) error

func (*DataStorer) Close

func (m *DataStorer) Close(ctx context.Context) error

func (*DataStorer) GetJob

func (ds *DataStorer) GetJob(jobID string) (*models.Job, error)

func (*DataStorer) GetJobs

func (ds *DataStorer) GetJobs(ctx context.Context, filter []string, offset int, limit int) (*models.JobResults, error)

func (*DataStorer) UpdateJob

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

func (*DataStorer) UpdateJobState

func (ds *DataStorer) UpdateJobState(string, string) error