StateAdapter

acquireLock(threadId: string, ttlMs: number): Promise<Lock | null>

appendToList(key: string, value: unknown, options?: { maxLength: number; ttlMs: number }): Promise<void>

connect(): Promise<void>

delete(key: string): Promise<void>

dequeue(threadId: string): Promise<QueueEntry | null>

disconnect(): Promise<void>

enqueue(threadId: string, entry: QueueEntry, maxSize: number): Promise<number>

extendLock(lock: Lock, ttlMs: number): Promise<boolean>

forceReleaseLock(threadId: string): Promise<void>

get(key: string): Promise<T | null>

getList(key: string): Promise<T[]>

isSubscribed(threadId: string): Promise<boolean>

queueDepth(threadId: string): Promise<number>

releaseLock(lock: Lock): Promise<void>

set(key: string, value: T, ttlMs?: number): Promise<void>

setIfNotExists(key: string, value: unknown, ttlMs?: number): Promise<boolean>

subscribe(threadId: string): Promise<void>

unsubscribe(threadId: string): Promise<void>