mongo

Documentation

Index

• type Mongo
  • func NewDatastore(ctx context.Context, uri, database, collection string) (m *Mongo, err error)
  • func (m *Mongo) AcquireInstanceLock(ctx context.Context, jobID string) (lockID string, err error)
  • func (m *Mongo) AddJob(job *models.Job) (*models.Job, error)
  • func (m *Mongo) AddUploadedFile(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(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(lockID string)
  • func (m *Mongo) UpdateJob(id string, job *models.Job) (err error)
  • func (m *Mongo) UpdateProcessedInstance(id string, procInstances []models.ProcessedInstances) (err error)

Types

type Mongo

type Mongo struct {
	Collection string
	Database   string
	URI        string
	Session    *mgo.Session
	// contains filtered or unexported fields
}

Mongo represents a simplistic MongoDB configuration

func NewDatastore

func NewDatastore(ctx context.Context, uri, database, collection string) (m *Mongo, err error)

NewDatastore creates a new mgo.Session with a strong consistency and a write mode of "majority"

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(job *models.Job) (*models.Job, error)

AddJob adds an ImportJob document

func (*Mongo) AddUploadedFile

func (m *Mongo) AddUploadedFile(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(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(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(id string, job *models.Job) (err error)

UpdateJob adds or overides an existing import job

func (*Mongo) UpdateProcessedInstance

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

UpdateProcessedInstance overides the processed instances for an existing import job