Index

_

__call__() (redis_allocator.allocator.RedisAllocatorUpdater method) __contains__() (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLockPool method) __enter__() (redis_allocator.allocator.RedisAllocatorObject method), [1] __exit__() (redis_allocator.allocator.RedisAllocatorObject method), [1] __init__() (redis_allocator.allocator.DefaultRedisAllocatorPolicy method) (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.allocator.RedisAllocatorObject method), [1] (redis_allocator.allocator.RedisAllocatorUpdater method) (redis_allocator.allocator.RedisThreadHealthCheckPool method), [1] (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot method) (redis_allocator.diagnostics.models.BindingDiagnostics method) (redis_allocator.diagnostics.models.OrphanDiagnostics method) (redis_allocator.diagnostics.models.PoolDiagnostics method) (redis_allocator.diagnostics.models.PressureDiagnostics method) (redis_allocator.diagnostics.RedisAllocatorDiagnostics method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLock method) (redis_allocator.lock.ThreadLockPool method) (redis_allocator.task_queue.RedisTask method), [1] (redis_allocator.task_queue.RedisTaskQueue method), [1]

__iter__() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method) __len__() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.allocator.RedisAllocatorUpdater method) (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method) __new__() (redis_allocator.lock.LockStatus method) _lock (redis_allocator.lock.ThreadLock attribute) (redis_allocator.lock.ThreadLockPool attribute) _locks (redis_allocator.lock.ThreadLock attribute) _pool (redis_allocator.lock.ThreadLockPool attribute) _save (redis_allocator.task_queue.RedisTask attribute), [1]

A

allocated_markers (redis_allocator.diagnostics.models.PoolDiagnostics attribute) ALLOCATED_SENTINEL (in module redis_allocator.allocator) allocator (redis_allocator.allocator.RedisAllocatorObject attribute), [1] allocator_keyspace_delta (redis_allocator.diagnostics.models.PressureDiagnostics attribute) AllocatorDiagnosticsSnapshot (class in redis_allocator.diagnostics.models)

assign() (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLockPool method) Auto (redis_allocator.task_queue.TaskExecutePolicy attribute), [1], [2], [3]

B

BaseLock (class in redis_allocator.lock) BaseLockPool (class in redis_allocator.lock)

BindingDiagnostics (class in redis_allocator.diagnostics.models) bindings (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute) build_task() (redis_allocator.task_queue.RedisTaskQueue method), [1]

C

check_health() (redis_allocator.allocator.RedisAllocatorPolicy method) check_health_once() (redis_allocator.allocator.RedisAllocatorPolicy method) clear() (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLockPool method)

close() (redis_allocator.allocator.RedisAllocatableClass method), [1] (redis_allocator.allocator.RedisAllocatorObject method), [1] command_deltas (redis_allocator.diagnostics.models.PressureDiagnostics attribute) count (redis_allocator.diagnostics.models.OrphanDiagnostics attribute) current_progress (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3] current_thread_id (redis_allocator.allocator.RedisThreadHealthCheckPool property), [1]

D

DefaultRedisAllocatorPolicy (class in redis_allocator.allocator) deleq() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) delge() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) delgt() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method)

delle() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) dellt() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) delne() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method)

E

eps (redis_allocator.allocator.RedisAllocator attribute), [1] (redis_allocator.lock.BaseLock attribute), [1] (redis_allocator.lock.BaseLockPool attribute) (redis_allocator.lock.RedisLock attribute), [1] (redis_allocator.lock.RedisLockPool attribute) (redis_allocator.lock.ThreadLock attribute) ERROR (redis_allocator.lock.LockStatus attribute) error (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3]

execute_task_locally() (redis_allocator.task_queue.RedisTaskQueue method), [1] execute_task_remotely() (redis_allocator.task_queue.RedisTaskQueue method), [1] expired_entries (redis_allocator.diagnostics.models.PoolDiagnostics attribute) expiry (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3] extend() (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLockPool method)

F

fetch() (redis_allocator.allocator.RedisAllocatorUpdater method) finalize() (redis_allocator.allocator.DefaultRedisAllocatorPolicy method) (redis_allocator.allocator.RedisThreadHealthCheckPool method), [1]

free (redis_allocator.diagnostics.models.PoolDiagnostics attribute) FREE (redis_allocator.lock.LockStatus attribute) free() (redis_allocator.allocator.RedisAllocator method), [1] free_keys() (redis_allocator.allocator.RedisAllocator method), [1]

G

gc() (redis_allocator.allocator.RedisAllocator method), [1] get_free_list() (redis_allocator.allocator.RedisAllocator method), [1]

get_soft_bind() (redis_allocator.allocator.RedisAllocator method), [1] get_task() (redis_allocator.task_queue.RedisTaskQueue method), [1]

H

has_task() (redis_allocator.task_queue.RedisTaskQueue method), [1] health (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute)

health_check() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method)

I

id (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3] identity (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute) initialize() (redis_allocator.allocator.DefaultRedisAllocatorPolicy method) (redis_allocator.allocator.RedisAllocatorPolicy method) (redis_allocator.allocator.RedisThreadHealthCheckPool method), [1] integrity (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute) interval (redis_allocator.task_queue.RedisTaskQueue attribute), [1] interval_seconds (redis_allocator.diagnostics.models.PressureDiagnostics attribute) is_healthy() (redis_allocator.allocator.RedisAllocatableClass method), [1] (redis_allocator.allocator.RedisAllocatorObject method), [1]

is_locked() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLock method) items_locked_status() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method)

K

key (redis_allocator.allocator.RedisAllocatorObject attribute), [1] key_status() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLock method)

keys() (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLockPool method)

L

listen() (redis_allocator.task_queue.RedisTaskQueue method), [1] Local (redis_allocator.task_queue.TaskExecutePolicy attribute), [1], [2], [3] LocalFirst (redis_allocator.task_queue.TaskExecutePolicy attribute), [1], [2], [3] lock() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLock method)

lock_value() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLock method) locked (redis_allocator.diagnostics.models.PoolDiagnostics attribute) LOCKED (redis_allocator.lock.LockStatus attribute) LockStatus (class in redis_allocator.lock)

M

malloc() (redis_allocator.allocator.DefaultRedisAllocatorPolicy method) (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.allocator.RedisAllocatorPolicy method) malloc_key() (redis_allocator.allocator.RedisAllocator method), [1]

module redis_allocator.allocator, [1] redis_allocator.diagnostics redis_allocator.lock redis_allocator.task_queue, [1]

N

name (redis_allocator.allocator.RedisAllocatableClass property), [1] (redis_allocator.allocator.RedisAllocatorObject property), [1] (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3]

O

obj (redis_allocator.allocator.RedisAllocatorObject attribute), [1] object_key() (redis_allocator.allocator.RedisAllocator method), [1] open() (redis_allocator.allocator.RedisAllocatableClass method), [1] (redis_allocator.allocator.RedisAllocatorObject method), [1]

OrphanDiagnostics (class in redis_allocator.diagnostics.models) orphans (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute)

P

params (redis_allocator.allocator.RedisAllocatorObject attribute), [1] (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3] permanent_locks (redis_allocator.diagnostics.models.PoolDiagnostics attribute) pool (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute) POOL_VALUE_SEP (in module redis_allocator.allocator) PoolDiagnostics (class in redis_allocator.diagnostics.models)

prefix (redis_allocator.allocator.RedisAllocator attribute), [1] (redis_allocator.lock.RedisLock attribute), [1] (redis_allocator.lock.RedisLockPool attribute) (redis_allocator.task_queue.RedisTaskQueue attribute), [1] pressure (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute) PressureDiagnostics (class in redis_allocator.diagnostics.models)

Q

query() (redis_allocator.task_queue.RedisTaskQueue method), [1]

R

reclaimable (redis_allocator.diagnostics.models.PoolDiagnostics attribute) recommendations (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute) redis (redis_allocator.allocator.RedisAllocator attribute), [1] (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute) (redis_allocator.lock.RedisLock attribute), [1] (redis_allocator.lock.RedisLockPool attribute) (redis_allocator.task_queue.RedisTaskQueue attribute), [1] redis_allocator.allocator module, [1] redis_allocator.diagnostics module redis_allocator.lock module redis_allocator.task_queue module, [1] redis_ops_per_sec (redis_allocator.diagnostics.models.PressureDiagnostics attribute) RedisAllocatableClass (class in redis_allocator.allocator), [1] RedisAllocator (class in redis_allocator.allocator), [1] RedisAllocatorDiagnostics (class in redis_allocator.diagnostics) RedisAllocatorObject (class in redis_allocator.allocator), [1] RedisAllocatorPolicy (class in redis_allocator.allocator)

RedisAllocatorUpdater (class in redis_allocator.allocator) RedisLock (class in redis_allocator.lock) RedisLockPool (class in redis_allocator.lock) RedisTask (class in redis_allocator.task_queue), [1] RedisTaskQueue (class in redis_allocator.task_queue), [1] RedisThreadHealthCheckPool (class in redis_allocator.allocator), [1] refresh() (redis_allocator.allocator.RedisAllocatorObject method), [1] refresh_pool() (redis_allocator.allocator.DefaultRedisAllocatorPolicy method) (redis_allocator.allocator.RedisAllocatorPolicy method) refresh_pool_all() (redis_allocator.allocator.DefaultRedisAllocatorPolicy method) (redis_allocator.allocator.RedisAllocatorPolicy method) refresh_until_healthy() (redis_allocator.allocator.RedisAllocatorObject method), [1] release() (redis_allocator.allocator.RedisAllocatorObject method), [1] Remote (redis_allocator.task_queue.TaskExecutePolicy attribute), [1], [2], [3] RemoteFirst (redis_allocator.task_queue.TaskExecutePolicy attribute), [1], [2], [3] result (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3] rlock() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLock method)

S

samples (redis_allocator.diagnostics.models.BindingDiagnostics attribute) (redis_allocator.diagnostics.models.OrphanDiagnostics attribute) save() (redis_allocator.task_queue.RedisTask method), [1] scanned (redis_allocator.diagnostics.models.BindingDiagnostics attribute) (redis_allocator.diagnostics.models.OrphanDiagnostics attribute) set_config() (redis_allocator.allocator.RedisAllocatableClass method), [1] set_healthy() (redis_allocator.allocator.RedisAllocatorObject method), [1] set_queue_listened() (redis_allocator.task_queue.RedisTaskQueue method), [1] set_task() (redis_allocator.task_queue.RedisTaskQueue method), [1] set_unhealthy() (redis_allocator.allocator.RedisAllocatorObject method), [1] seteq() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) setge() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) setgt() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method)

setle() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) setlt() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) setne() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) shrink() (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLockPool method) snapshot() (redis_allocator.diagnostics.RedisAllocatorDiagnostics method) snapshot_json() (redis_allocator.diagnostics.RedisAllocatorDiagnostics method) stale (redis_allocator.diagnostics.models.BindingDiagnostics attribute) suffix (redis_allocator.allocator.RedisAllocator attribute), [1] (redis_allocator.lock.RedisLock attribute), [1] (redis_allocator.lock.RedisLockPool attribute) (redis_allocator.task_queue.RedisTaskQueue attribute), [1]

T

task_fn (redis_allocator.task_queue.RedisTaskQueue attribute), [1] TaskExecutePolicy (class in redis_allocator.task_queue), [1] ThreadLock (class in redis_allocator.lock) ThreadLockPool (class in redis_allocator.lock) timeout (redis_allocator.task_queue.RedisTaskQueue attribute), [1]

timestamp (redis_allocator.diagnostics.models.AllocatorDiagnosticsSnapshot attribute) total (redis_allocator.diagnostics.models.BindingDiagnostics attribute) (redis_allocator.diagnostics.models.PoolDiagnostics attribute) total_progress (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3] truncated (redis_allocator.diagnostics.models.BindingDiagnostics attribute) (redis_allocator.diagnostics.models.OrphanDiagnostics attribute)

U

UNAVAILABLE (redis_allocator.lock.LockStatus attribute) unbind_soft_bind() (redis_allocator.allocator.RedisAllocator method), [1] unique_id (redis_allocator.allocator.RedisAllocatableClass property), [1] (redis_allocator.allocator.RedisAllocatorObject property), [1] unlock() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLock method)

update() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.allocator.RedisAllocatorObject method), [1] (redis_allocator.allocator.RedisThreadHealthCheckPool method), [1] (redis_allocator.lock.BaseLock method) (redis_allocator.lock.RedisLock method) (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLock method) (redis_allocator.task_queue.RedisTask method), [1] update_progress_time (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3] update_soft_bind() (redis_allocator.allocator.RedisAllocator method), [1]

V

values_lock_status() (redis_allocator.allocator.RedisAllocator method) (redis_allocator.lock.BaseLockPool method) (redis_allocator.lock.RedisLockPool method)