Options
All
  • Public
  • Public/Protected
  • All
Menu

Class InMemoryPartitionManager

Package version

The EventProcessor relies on a PartitionManager to store checkpoints and handle partition ownerships. InMemoryPartitionManager is simple partition manager that stores checkpoints and partition ownerships in memory of your program.

You can use the InMemoryPartitionManager to get started with using the EventProcessor. But in production, you should choose an implementation of the PartitionManager interface that will store the checkpoints and partition ownerships to a durable store instead.

class

Hierarchy

  • InMemoryPartitionManager

Implements

Index

Methods

claimOwnership

listOwnership

  • listOwnership(fullyQualifiedNamespace: string, eventHubName: string, consumerGroupName: string): Promise<PartitionOwnership[]>
  • Get the list of all existing partition ownership from the underlying data store. Could return empty results if there are is no existing ownership information.

    Parameters

    • fullyQualifiedNamespace: string

      The fully qualified Event Hubs namespace. This is likely to be similar to .servicebus.windows.net.

    • eventHubName: string

      The event hub name.

    • consumerGroupName: string

      The consumer group name.

    Returns Promise<PartitionOwnership[]>

    Partition ownership details of all the partitions that have/had an owner..

updateCheckpoint

  • updateCheckpoint(checkpoint: Checkpoint): Promise<string>

Generated using TypeDoc