faust.stores.aerospike

Aerospike storage.

class faust.stores.aerospike.Client

Dummy Client.

exception faust.stores.aerospike.RecordNotFound

Dummy Exception.

class faust.stores.aerospike.AeroSpikeStore(url: Union[str, URL], app: AppT, table: CollectionT, options: Optional[Mapping[str, Any]] = None, **kwargs: Any)

Aerospike table storage.

BIN_KEY = 'value_key'

USERNAME_KEY: str = 'user'

HOSTS_KEY: str = 'hosts'

PASSWORD_KEY: str = 'password'

NAMESPACE_KEY: str = 'namespace'

TTL_KEY: str = 'ttl'

POLICIES_KEY: str = 'policies'

CLIENT_OPTIONS_KEY: str = 'client'

client: Client

ttl: int

policies: Mapping[str, Any]

static get_aerospike_client(aerospike_config: Dict[Any, Any]) → Client

Try to get Aerospike client instance.

Return type:

Client

logger: logging.Logger = <Logger faust.stores.aerospike (WARNING)>

reset_state() → None

Remove system state.

This does nothing when using the Aerospike store.

Return type:

None

persisted_offset(tp: TP) → Optional[int]

Return the persisted offset.

This always returns None when using the aerospike store.

Return type:

_UnionGenericAlias[int, None]

aerospike_fun_call_with_retry(fun, *args, **kwargs)

Call function and retry until Aerospike throws exception.

async backup_partition(tp: Union[TP, int], flush: bool = True, purge: bool = False, keep: int = 1) → None

Backup partition from this store.

Not yet implemented for Aerospike.

Return type:

None

restore_backup(tp: Union[TP, int], latest: bool = True, backup_id: int = 0) → None

Restore partition backup from this store.

Not yet implemented for Aerospike.

Return type:

None