Index

_

__call__() (redis_allocator.allocator.RedisAllocatorUpdater method) __contains__() (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.lock.RedisLockPool method) (redis_allocator.lock.ThreadLockPool method) __init__() (redis_allocator.allocator.DefaultRedisAllocatorPolicy method) (redis_allocator.allocator.RedisAllocator method), [1] (redis_allocator.allocator.RedisAllocatorObject method) (redis_allocator.allocator.RedisAllocatorUpdater method) (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.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

allocator (redis_allocator.allocator.RedisAllocatorObject attribute) 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]

B

BaseLock (class in redis_allocator.lock)

BaseLockPool (class in redis_allocator.lock) 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) 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] 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.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_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] initialize() (redis_allocator.allocator.DefaultRedisAllocatorPolicy method) (redis_allocator.allocator.RedisAllocatorPolicy method) (redis_allocator.allocator.RedisThreadHealthCheckPool method), [1] interval (redis_allocator.task_queue.RedisTaskQueue attribute), [1] is_healthy() (redis_allocator.allocator.RedisAllocatableClass method), [1] (redis_allocator.allocator.RedisAllocatorObject method)

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) 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] LocalFirst (redis_allocator.task_queue.TaskExecutePolicy attribute), [1] 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.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.lock redis_allocator.task_queue, [1]

N

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

O

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

open() (redis_allocator.allocator.RedisAllocatableClass method), [1] (redis_allocator.allocator.RedisAllocatorObject method)

P

params (redis_allocator.allocator.RedisAllocatorObject attribute) (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3] 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]

Q

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

R

redis (redis_allocator.allocator.RedisAllocator attribute), [1] (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.lock module redis_allocator.task_queue module, [1] RedisAllocatableClass (class in redis_allocator.allocator), [1] RedisAllocator (class in redis_allocator.allocator), [1] RedisAllocatorObject (class in redis_allocator.allocator) 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) 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) Remote (redis_allocator.task_queue.TaskExecutePolicy attribute), [1] RemoteFirst (redis_allocator.task_queue.TaskExecutePolicy attribute), [1] 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

save() (redis_allocator.task_queue.RedisTask method), [1] set_config() (redis_allocator.allocator.RedisAllocatableClass method), [1] set_healthy() (redis_allocator.allocator.RedisAllocatorObject method) 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) 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) 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) ThreadLock (class in redis_allocator.lock)

ThreadLockPool (class in redis_allocator.lock) timeout (redis_allocator.task_queue.RedisTaskQueue attribute), [1] total_progress (redis_allocator.task_queue.RedisTask attribute), [1], [2], [3]

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) 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) (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)