import type { Id } from '../identifier.utils.js'; import type { ClientProvider } from '../../client/index.js'; /** * Creates a virtual command that ensures a consumer group exists. * If the group does not exist, it will be created. * * @param c - Client provider function * @returns Function that ensures a consumer group exists by name */ export declare const ensureConsumerGroup: (c: ClientProvider) => (streamId: Id, topicId: Id, groupName: string) => Promise; /** * Creates a virtual command that ensures a consumer group exists and joins it. * If the group does not exist, it will be created, then the client joins the group. * * @param c - Client provider function * @returns Function that ensures a consumer group exists and joins it */ export declare const ensureConsumerGroupAndJoin: (c: ClientProvider) => (streamId: Id, topicId: Id, groupName: string) => Promise; //# sourceMappingURL=ensure-group.virtual.command.d.ts.map