store

type AcquireLockResult struct {
	LockedBy       string
	LeaseExpiresAt time.Time
}

type LockStatus struct {
	Locked         bool
	LockedBy       *string
	LeaseExpiresAt *time.Time
	UpdatedAt      *time.Time
}

type LockStore interface {
	// CreateLockTable creates the lock table if it doesn't exist. Implementations should ensure
	// that this operation is idempotent.
	CreateLockTable(ctx context.Context, db *sql.DB) error
	// TableExists checks if the lock table exists.
	TableExists(ctx context.Context, db *sql.DB) (bool, error)
	// AcquireLock attempts to acquire a lock for the given lockID.
	AcquireLock(ctx context.Context, db *sql.DB, lockID int64, lockedBy string, leaseDuration time.Duration) (*AcquireLockResult, error)
	// ReleaseLock releases a lock held by the current instance.
	ReleaseLock(ctx context.Context, db *sql.DB, lockID int64, lockedBy string) (*ReleaseLockResult, error)
	// UpdateLease updates the lease expiration time for a lock (heartbeat).
	UpdateLease(ctx context.Context, db *sql.DB, lockID int64, lockedBy string, leaseDuration time.Duration) (*UpdateLeaseResult, error)
	// CheckLockStatus checks the current status of a lock.
	CheckLockStatus(ctx context.Context, db *sql.DB, lockID int64) (*LockStatus, error)
	// CleanupStaleLocks removes any locks that have expired using server time. Returns the list of
	// lock IDs that were cleaned up, if any.
	CleanupStaleLocks(ctx context.Context, db *sql.DB) ([]int64, error)
}

type ReleaseLockResult struct {
	LockID int64
}

type UpdateLeaseResult struct {
	LeaseExpiresAt time.Time
}