mongo

Documentation

Index

• type Mongo
  • func NewMongoStore(ctx context.Context, cfg config.MongoConfig) (m *Mongo, err error)
  • func (m *Mongo) AcquireImageLock(ctx context.Context, imageID string) (lockID string, err error)
  • func (m *Mongo) Checker(ctx context.Context, state *healthcheck.CheckState) error
  • func (m *Mongo) Close(ctx context.Context) error
  • func (m *Mongo) GetImage(ctx context.Context, id string) (*models.Image, error)
  • func (m *Mongo) GetImages(ctx context.Context, collectionID string) ([]models.Image, error)
  • func (m *Mongo) UnlockImage(ctx context.Context, lockID string)
  • func (m *Mongo) UpdateImage(ctx context.Context, id string, image *models.Image) (bool, error)
  • func (m *Mongo) UpsertImage(ctx context.Context, id string, image *models.Image) (err error)

Types

type Mongo

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

func NewMongoStore

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

NewMongoStore creates a new Mongo object encapsulating a connection to the mongo server/cluster with the given configuration, and a health client to check the health of the mongo server/cluster

func (*Mongo) AcquireImageLock

func (m *Mongo) AcquireImageLock(ctx context.Context, imageID string) (lockID string, err error)

AcquireImageLock tries to lock the provided imageID. If the image is already locked, this function will block until it's released, at which point we acquire the lock and return.

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 closes the mongo session and returns any error

func (*Mongo) GetImage

func (m *Mongo) GetImage(ctx context.Context, id string) (*models.Image, error)

GetImage retrieves an image document by its ID

func (*Mongo) GetImages

func (m *Mongo) GetImages(ctx context.Context, collectionID string) ([]models.Image, error)

GetImages retrieves all images documents corresponding to the provided collectionID

func (*Mongo) UnlockImage

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

UnlockImage releases an exclusive mongoDB lock for the provided lockId (if it exists)

func (*Mongo) UpdateImage

func (m *Mongo) UpdateImage(ctx context.Context, id string, image *models.Image) (bool, error)

UpdateImage updates an existing image document

func (*Mongo) UpsertImage

func (m *Mongo) UpsertImage(ctx context.Context, id string, image *models.Image) (err error)

UpsertImage adds or overides an existing image document