mongo

package

v1.6.1 Latest Latest Go to latest Published: Dec 8, 2025 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Mongo struct {
	mongoDriver.MongoDriverConfig

	Connection *mongoDriver.MongoConnection
	// contains filtered or unexported fields
}

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

NewMongoStore creates a connection to mongo database

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 (m *Mongo) Close(ctx context.Context) error

Close closes the connection to the database

func (m *Mongo) GetCacheTime(ctx context.Context, id string) (*models.CacheTime, error)

GetCacheTime returns a cache time with its given id

func (m *Mongo) IsConnected(ctx context.Context) bool

IsConnected return the connection status to the db

func (m *Mongo) UpsertCacheTime(ctx context.Context, cacheTime *models.CacheTime) (err error)

UpsertCacheTime adds or overrides an existing cache time