Type Alias HotMeshEngine

Type declaration

• Optionalconnection?: ProviderConfig

  short-form format for the connection options for the store, stream, sub, and search clients

• Optionalconnections?: {
      search?: ProviderConfig;
      store: ProviderConfig;
      stream: ProviderConfig;
      sub: ProviderConfig;
  }

  long-form format for the connection options for the store, stream, sub, and search clients

  • Optionalsearch?: ProviderConfig

  • store: ProviderConfig

  • stream: ProviderConfig

  • sub: ProviderConfig

• Optionalreadonly?: boolean

  if true, the engine will not route stream messages to the worker

  Default

  false
  Copy

• OptionalreclaimCount?: number

  the number of times to reclaim a stream before giving up and moving the message to a dead-letter queue or other error handling mechanism

• OptionalreclaimDelay?: number

  the number of milliseconds to wait before reclaiming a stream; depending upon the provider this may be an explicit retry event, consuming a message from the stream and re-queueing it (dlq, etc), or it may be a configurable delay before the provider exposes the message to the consumer again. It is up to the provider, but expressed in milliseconds here.

• Optionalredis?: ProviderConfig

  redis connection options; replaced with 'connection'

  Deprecated