Interface StreamConfig

interface StreamConfig {
    appId?: string;
    batchSize?: number;
    maxRetries?: number;
    namespace?: string;
    nats?: {
        ackWait?: number;
        deliverPolicy?:
            | "all"
            | "new"
            | "last"
            | "byStartSequence"
            | "byStartTime";
        durableName?: string;
        jetstream?: boolean;
    };
    postgres?: {
        cleanupInterval?: number;
        partitionInterval?: "daily" | "weekly" | "monthly";
        pollInterval?: number;
        vacuumInterval?: number;
    };
    provider?: StreamProviderType;
    redis?: {
        blockingTimeout?: number;
        claimTimeout?: number;
        minIdleTime?: number;
    };
    sqs?: {
        deadLetterQueue?: string;
        dlqArn?: string;
        messageRetentionPeriod?: number;
        visibilityTimeout?: number;
        waitTimeSeconds?: number;
    };
    timeout?: number;
}

Properties

appId? batchSize? maxRetries? namespace? nats? postgres? provider? redis? sqs? timeout?

Properties

OptionalappId

appId?: string

OptionalbatchSize

batchSize?: number

OptionalmaxRetries

maxRetries?: number

Optionalnamespace

namespace?: string

Optionalnats

nats?: {
    ackWait?: number;
    deliverPolicy?:
        | "all"
        | "new"
        | "last"
        | "byStartSequence"
        | "byStartTime";
    durableName?: string;
    jetstream?: boolean;
}

Optionalpostgres

postgres?: {
    cleanupInterval?: number;
    partitionInterval?: "daily" | "weekly" | "monthly";
    pollInterval?: number;
    vacuumInterval?: number;
}

Optionalprovider

provider?: StreamProviderType

Optionalredis

redis?: {
    blockingTimeout?: number;
    claimTimeout?: number;
    minIdleTime?: number;
}

Optionalsqs

sqs?: {
    deadLetterQueue?: string;
    dlqArn?: string;
    messageRetentionPeriod?: number;
    visibilityTimeout?: number;
    waitTimeSeconds?: number;
}

Optionaltimeout

timeout?: number

Settings

Member Visibility

On This Page

Properties