RedisSMQ Common Library / Docs / API
- AbortError
- CallbackEmptyReplyError
- CallbackInvalidReplyError
- EventBus
- EventBusError
- EventBusNotConnectedError
- EventBusRedis
- EventEmitter
- IoredisClient
- IoredisClientMulti
- LockAcquireError
- LockError
- LockExtendError
- LockMethodNotAllowedError
- LockNotAcquiredError
- Locker
- LoggerError
- LuaScript
- NodeRedisClient
- NodeRedisClientMulti
- PanicError
- PowerSwitch
- RedisClientAbstract
- RedisClientError
- RedisSMQError
- Runnable
- Timer
- TimerError
- WatchedKeysChangedError
- WorkerAlreadyDownError
- WorkerAlreadyRunningError
- WorkerCallable
- WorkerError
- WorkerPayloadRequiredError
- WorkerResourceGroup
- WorkerRunnable
- WorkerThreadError
- ICallback
- IEventBus
- IEventEmitter
- ILogger
- ILoggerConfig
- IRedisClient
- IRedisConfigIORedis
- IRedisConfigNodeRedis
- IRedisTransaction
- IWorkerCallable
- IWorkerData
- IWorkerRunnable
- IRedisConfig
- TEventBusEvent
- TEventEmitterEvent
- TFunction
- TLockerEvent
- TRedisClientEvent
- TRedisClientNodeRedis
- TRedisTransactionNodeRedis
- TTimer
- TTimerEvent
- TUnaryFunction
- TWorkerFn
- TWorkerResourceGroupEvent
- TWorkerThreadError
- TWorkerThreadMessage
- TWorkerThreadMessageCode
Ƭ IRedisConfig: IRedisConfigIORedis
| IRedisConfigNodeRedis
Ƭ TEventBusEvent: TEventEmitterEvent
& { error
: (err
: Error
) => void
}
Ƭ TEventEmitterEvent: Record
<string
, (...args
: any
[]) => void
>
Ƭ TFunction<TReturn
, TArgs
>: (...args
: TArgs
[]) => TReturn
Name | Type |
---|---|
TReturn |
void |
TArgs |
any |
▸ (...args
): TReturn
Name | Type |
---|---|
...args |
TArgs [] |
TReturn
Ƭ TLockerEvent: Object
Name | Type |
---|---|
locker.down |
(id : string ) => void |
locker.error |
(error : Error , id : string ) => void |
locker.goingDown |
(id : string ) => void |
locker.goingUp |
(id : string ) => void |
locker.up |
(id : string ) => void |
Ƭ TRedisClientEvent: Object
Name | Type |
---|---|
end |
() => void |
error |
(err : Error ) => void |
message |
(channel : string , message : string ) => void |
pmessage |
(pattern : string , channel : string , message : string ) => void |
ready |
() => void |
Ƭ TRedisClientNodeRedis: RedisClientType
<RedisModules
, RedisFunctions
, RedisScripts
>
Ƭ TRedisTransactionNodeRedis: RedisClientMultiCommandType
<RedisModules
, RedisFunctions
, RedisScripts
>
Ƭ TTimer: Object
Name | Type |
---|---|
fn |
TFunction |
periodic |
boolean |
timer |
NodeJS.Timeout |
Ƭ TTimerEvent: Object
Name | Type |
---|---|
error |
(err : Error ) => void |
Ƭ TUnaryFunction<T
, E
>: (reply
: T
) => E
Name | Type |
---|---|
T |
T |
E |
void |
▸ (reply
): E
Name | Type |
---|---|
reply |
T |
E
Ƭ TWorkerFn: (...args
: [...any[], ICallback
<any
>]) => void
▸ (...args
): void
Name | Type |
---|---|
...args |
[...any[], ICallback <any >] |
void
Ƭ TWorkerResourceGroupEvent: Object
Name | Type |
---|---|
workerResourceGroup.error |
(err : Error ) => void |
Ƭ TWorkerThreadError: Object
Name | Type |
---|---|
message |
string |
name |
string |
Ƭ TWorkerThreadMessage: Object
Name | Type |
---|---|
code |
TWorkerThreadMessageCode |
data? |
unknown |
error? |
TWorkerThreadError | null |
Ƭ TWorkerThreadMessageCode: EWorkerThreadExitCode
| EWorkerThreadExecutionCode
• Const
async: Object
Name | Type |
---|---|
each |
<T>(collection : Record <string , T > | T [], iteratee : (item : T , key : string | number , callback : ICallback <void >) => void , callback : ICallback <void >) => void |
eachIn |
<T>(collection : Record <string , T >, iteratee : (item : T , key : string , callback : ICallback <void >) => void , callback : ICallback <void >) => void |
eachOf |
<T>(collection : T [], iteratee : (item : T , key : number , callback : ICallback <void >) => void , callback : ICallback <void >) => void |
waterfall |
<T>(tasks : TFunction [], callback : ICallback <T >) => void |
• Const
logger: Object
Name | Type |
---|---|
destroy |
() => void |
getLogger |
(cfg : ILoggerConfig , ns? : string ) => ILogger |
setLogger |
<T>(logger : T ) => void |
▸ createRedisClient(config
, cb
): void
Name | Type |
---|---|
config |
IRedisConfig |
cb |
ICallback <IRedisClient > |
void
▸ getDirname(): string
string