swh.objstorage.backends.winery.sharedbase module

class swh.objstorage.backends.winery.sharedbase.ShardState(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

STANDBY = 'standby'

WRITING = 'writing'

FULL = 'full'

PACKING = 'packing'

PACKED = 'packed'

READONLY = 'readonly'

property locked

property readonly_available

class swh.objstorage.backends.winery.sharedbase.SharedBase(**kwargs)

Bases: Database

uninit()

property lock

Return an arbitrary unique number for pg_advisory_lock when creating tables

property database_tables

Return the list of CREATE TABLE statements for all tables in the database

property locked_shard: str

property locked_shard_id: int

set_locked_shard() → None

lock_one_shard(current_state: ShardState, new_state: ShardState) → Tuple[str, int] | None

Lock one shard in current_state, putting it into new_state

set_shard_state(new_state: ShardState, set_locker: bool = False, check_locker: bool = False, name: str | None = None)

create_shard(new_state: ShardState) → Tuple[str, int]

shard_packing_starts(name: str)

shard_packing_ends(name)

get_shard_info(id: int) → Tuple[str, ShardState] | None

list_shards() → Iterator[Tuple[str, ShardState]]

contains(obj_id) → int | None

get(obj_id) → Tuple[str, ShardState] | None

add_phase_1(obj_id) → int | None

add_phase_2(obj_id)