XREADGROUP.d.ts 783 B

1234567891011121314
  1. import { RedisCommandArgument, RedisCommandArguments } from '.';
  2. export interface XReadGroupStream {
  3. key: RedisCommandArgument;
  4. id: RedisCommandArgument;
  5. }
  6. export interface XReadGroupOptions {
  7. COUNT?: number;
  8. BLOCK?: number;
  9. NOACK?: true;
  10. }
  11. export declare const FIRST_KEY_INDEX: (_group: RedisCommandArgument, _consumer: RedisCommandArgument, streams: Array<XReadGroupStream> | XReadGroupStream) => RedisCommandArgument;
  12. export declare const IS_READ_ONLY = true;
  13. export declare function transformArguments(group: RedisCommandArgument, consumer: RedisCommandArgument, streams: Array<XReadGroupStream> | XReadGroupStream, options?: XReadGroupOptions): RedisCommandArguments;
  14. export { transformStreamsMessagesReply as transformReply } from './generic-transformers';