mongo

Documentation

Index

• type Mongo
  • func NewDatastore(uri, database, collection string) (*Mongo, error)
  • func (m *Mongo) AddJob(job *models.Job) (*models.Job, error)
  • func (m *Mongo) AddUploadedFile(id string, file *models.UploadedFile) error
  • func (m *Mongo) Close(ctx context.Context) error
  • func (m *Mongo) GetJob(id string) (*models.Job, error)
  • func (m *Mongo) GetJobs(filters []string) ([]models.Job, error)
  • func (m *Mongo) HealthCheckClient() *mongohealth.CheckMongoClient
  • func (m *Mongo) UpdateJob(id string, job *models.Job) (err error)
  • func (m *Mongo) UpdateJobState(id, newState string) (err error)

Types

type Mongo

type Mongo struct {
	Collection string
	Database   string
	URI        string
}

Mongo represents a simplistic MongoDB configuration

func NewDatastore

func NewDatastore(uri, database, collection string) (*Mongo, error)

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

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) 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(filters []string) ([]models.Job, error)

GetJobs retrieves all import documents matching filters

func (*Mongo) HealthCheckClient

func (m *Mongo) HealthCheckClient() *mongohealth.CheckMongoClient

func (*Mongo) UpdateJob

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

UpdateJob adds or overides an existing import job

func (*Mongo) UpdateJobState

func (m *Mongo) UpdateJobState(id, newState string) (err error)

UpdateJobState changes the state attribute of an import job