Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface HostContextWithPumpManager

Package version

Hierarchy

  • HostContextWithCheckpointLeaseManager
    • HostContextWithPumpManager

Index

Properties

Methods

Properties

blobReferenceByPartition

blobReferenceByPartition: Dictionary<AzureBlob>

Optional blobService

blobService: BlobService

checkpointLock

checkpointLock: AsyncLock

checkpointLockId

checkpointLockId: string

checkpointManager

checkpointManager: CheckpointManager

composedBlobPrefix

composedBlobPrefix: string

connectionConfig

connectionConfig: EventHubConnectionConfig

consumerGroup

consumerGroup: string

eventHubConnectionString

eventHubConnectionString: string

eventHubPath

eventHubPath: string

Optional fastScanInterval

fastScanInterval: undefined | number

hostName

hostName: string

Optional initialOffset

initialOffset: EventPosition

leaseDuration

leaseDuration: number

leaseManager

leaseManager: LeaseManager

leaseRenewInterval

leaseRenewInterval: number

onEphError

onEphError: OnEphError

Optional onError

onError: OnReceivedError

Optional onMessage

onMessage: OnReceivedMessage

partitionIds

partitionIds: string[]

pumpManager

pumpManager: PumpManager

pumps

pumps: Map<string, PartitionPump>

Optional slowScanInterval

slowScanInterval: undefined | number

Optional startupScanDelay

startupScanDelay: undefined | number

Optional storageBlobPrefix

storageBlobPrefix: undefined | string

Optional storageConnectionString

storageConnectionString: undefined | string

Optional storageContainerName

storageContainerName: undefined | string

Optional tokenProvider

tokenProvider: TokenProvider

userAgent

userAgent: string

Methods

getEventHubClient

  • getEventHubClient(): EventHubClient

  • Returns EventHubClient

getHubRuntimeInformation

  • getHubRuntimeInformation(): Promise<EventHubRuntimeInformation>

  • Returns Promise<EventHubRuntimeInformation>

getPartitionIds

  • getPartitionIds(): Promise<string[]>

  • Returns Promise<string[]>

getPartitionInformation

  • getPartitionInformation(partitionId: string | number): Promise<EventHubPartitionRuntimeInformation>

  • Parameters

    • partitionId: string | number

    Returns Promise<EventHubPartitionRuntimeInformation>

withHost

  • withHost(msg: string): string

  • Parameters

    • msg: string

    Returns string

withHostAndPartition

  • withHostAndPartition(partition: string | object, msg: string): string

  • Parameters

    • partition: string | object
    • msg: string

    Returns string

Generated using TypeDoc