lockmanager

type GroupConfig struct {
	Slots int `yaml:"slots"`
}

type Groups map[string]GroupConfig

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

type StorageBackend interface {
	// 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
	Reserve(group, id string) error
	// Returns the current number of locks for the given group
	GetLocks(group string) (int, error)
	// Release the lock currently held by the id.
	// Does not fail when no lock is held.
	Release(group, id string) error
	// Return all locks older than x
	GetStaleLocks(ts time.Duration) ([]types.Lock, error)
	// Check if a given id already has a lock for this group
	HasLock(group, id string) (bool, error)
	// Calls all necessary finalization if necessary
	Close() error
}

type StorageConfig struct {
	Type       string                      `yaml:"type"`
	SQLite     sql.SQLiteConfig            `yaml:"sqlite,omitempty"`
	Postgres   sql.PostgresConfig          `yaml:"postgres,omitempty"`
	MySQL      sql.MySQLConfig             `yaml:"mysql,omitempty"`
	Valkey     valkey.ValkeyConfig         `yaml:"valkey,omitempty"`
	Etcd       etcd.EtcdConfig             `yaml:"etcd,omitempty"`
	Kubernetes kubernetes.KubernetesConfig `yaml:"kubernetes,omitempty"`
	MongoDB    mongodb.MongoDBConfig       `yaml:"mongodb,omitempty"`
}