mongo

Documentation

Index

• type Mongo
  • func NewDatastore(ctx context.Context, cfg config.MongoConfig) (m *Mongo, err error)
  • func (m *Mongo) AcquireInstanceLock(ctx context.Context, jobID string) (lockID string, err error)
  • func (m *Mongo) AddJob(ctx context.Context, job *models.Job) (*models.Job, error)
  • func (m *Mongo) AddUploadedFile(ctx context.Context, id string, file *models.UploadedFile) error
  • func (m *Mongo) Checker(ctx context.Context, state *healthcheck.CheckState) error
  • func (m *Mongo) Close(ctx context.Context) error
  • func (m *Mongo) GetJob(ctx context.Context, id string) (*models.Job, error)
  • func (m *Mongo) GetJobs(ctx context.Context, filters []string, offset int, limit int) (*models.JobResults, error)
  • func (m *Mongo) UnlockInstance(ctx context.Context, lockID string)
  • func (m *Mongo) UpdateJob(ctx context.Context, id string, job *models.Job) (err error)
  • func (m *Mongo) UpdateProcessedInstance(ctx context.Context, id string, procInstances []models.ProcessedInstances) (err error)

Types

type Mongo

type Mongo struct {
	mongodriver.MongoDriverConfig
	// contains filtered or unexported fields
}

func NewDatastore

func NewDatastore(ctx context.Context, cfg config.MongoConfig) (m *Mongo, err error)

NewDatastore creates a new mongodb.MongoConnection with the given configuration

func (*Mongo) AcquireInstanceLock

func (m *Mongo) AcquireInstanceLock(ctx context.Context, jobID string) (lockID string, err error)

AcquireInstanceLock tries to lock the provided jobID. If the job is already locked, this function will block until it's released, at which point we acquire the lock and return. Note: the lock is currently only used to update processed_instances

func (*Mongo) AddJob

func (m *Mongo) AddJob(ctx context.Context, job *models.Job) (*models.Job, error)

AddJob adds an ImportJob document - the ID is assumed to be set

func (*Mongo) AddUploadedFile

func (m *Mongo) AddUploadedFile(ctx context.Context, id string, file *models.UploadedFile) error

AddUploadedFile adds an UploadedFile to an import job

func (*Mongo) Checker

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

Checker is called by the healthcheck library to check the health state of this mongoDB instance

func (*Mongo) Close

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

Close disconnects the mongo session

func (*Mongo) GetJob

func (m *Mongo) GetJob(ctx context.Context, id string) (*models.Job, error)

GetJob retrieves a single import job

func (*Mongo) GetJobs

func (m *Mongo) GetJobs(ctx context.Context, filters []string, offset int, limit int) (*models.JobResults, error)

GetJobs retrieves all import documents matching filters

func (*Mongo) UnlockInstance

func (m *Mongo) UnlockInstance(ctx context.Context, lockID string)

UnlockInstance releases an exclusive mongoDB lock for the provided lockId (if it exists) Note: the lock is currently only used to update processed_instances

func (*Mongo) UpdateJob

func (m *Mongo) UpdateJob(ctx context.Context, id string, job *models.Job) (err error)

UpdateJob adds or overides an existing import job

func (*Mongo) UpdateProcessedInstance

func (m *Mongo) UpdateProcessedInstance(ctx context.Context, id string, procInstances []models.ProcessedInstances) (err error)

UpdateProcessedInstance overides the processed instances for an existing import job