Documentation
¶
Index ¶
- type Mongo
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Mongo ¶
type Mongo struct {
mongodriver.MongoDriverConfig
// contains filtered or unexported fields
}
func NewMongoStore ¶ added in v1.3.0
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 ¶ added in v0.8.0
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) GetImages ¶ added in v0.3.0
GetImages retrieves all images documents corresponding to the provided collectionID
func (*Mongo) UnlockImage ¶ added in v0.8.0
UnlockImage releases an exclusive mongoDB lock for the provided lockId (if it exists)
func (*Mongo) UpdateImage ¶ added in v0.3.0
UpdateImage updates an existing image document
Source Files