swh.counters.api.client module#

class swh.counters.api.client.RemoteCounters(url: str, timeout: None | Tuple[float, float] | List[float] | float = None, chunk_size: int = 4096, max_retries: int = 3, pool_connections: int = 20, pool_maxsize: int = 100, adapter_kwargs: Dict[str, Any] | None = None, api_exception: Type[Exception] | None = None, reraise_exceptions: List[Type[Exception]] | None = None, **kwargs)[source]#

Bases: RPCClient

Proxy to a remote counters API

backend_class#: alias of CountersInterface

add(collection: str, keys: Iterable[Any]) → None#: Add the provided keys to the collection Only count new keys.

check()#: Dedicated method to execute some specific check per implementation.

get_count(collection: str) → int#: Return the number of keys for the provided collection

get_counters() → Iterable[str]#: Return the list of managed counters

get_counts(collections: List[str]) → Dict[str, int]#: Return the number of keys for the provided collection