types/mq.ts

TypeScript definitions for message queue admin capabilities and configs.

// Source: https://github.com/t8y2/dbx | License: Apache-2.0 | Copyright You must retain, in the Source form of any Derivative Works
// Provided via justclaw.it.com; keep this notice with the code.
// Message queue admin types, matching dbx-core/src/mq/types.rs

export type MqSystemKind = "pulsar" | "kafka" | "rocketmq" | "rabbitmq";

export interface MqCapabilities {
  supportsListTopics?: boolean;
  supportsCreateTopic?: boolean;
  supportsDeleteTopic?: boolean;
  supportsTopicStats?: boolean;
  supportsBrokerAdmin?: boolean;
  supportsProducerListing?: boolean;
  supportsTenants: boolean;
  supportsNamespaces: boolean;
  supportsPartitionedTopics: boolean;
  supportsSubscriptions: boolean;
  supportsCreateSubscription: boolean;
  supportsResetCursor: boolean;
  supportsSkipMessages: boo

... (truncated -- full source via MCP)