mongodb

package

v1.11.3 Latest Latest Go to latest Published: Jul 12, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation ¶

const DEFAULT_DATABASE = "fleetlock"

This section is empty.

This section is empty.

type MongoDBBackend struct {
	// contains filtered or unexported fields
}

func NewMongoDBBackend(cfg MongoDBConfig) (*MongoDBBackend, error)

func (m *MongoDBBackend) Close() error

Calls all necessary finalization if necessary

func (m *MongoDBBackend) GetLocks(group string) (int, error)

Returns the current number of locks for the given group

func (m *MongoDBBackend) GetStaleLocks(ts time.Duration) ([]types.Lock, error)

Return all locks older than x

func (m *MongoDBBackend) HasLock(group string, id string) (bool, error)

Check if a given id already has a lock for this group

func (m *MongoDBBackend) Release(group string, id string) error

Release the lock currently held by the id. Does not fail when no lock is held.

func (m *MongoDBBackend) Reserve(group string, id string) error

Reserve a lock for the given group. Returns true if the lock is successfully reserved, even if the lock is already held by the specific id

type MongoDBConfig struct {
	URL      string `yaml:"url,omitempty"`
	Database string `yaml:"database,omitempty"`
}

type MongoLock struct {
	ID      string    `bson:"_id,omitempty"`
	Created time.Time `bson:"created,omitempty"`
}