Versions in this module Expand all Collapse all v3 v3.3.39 Oct 20, 2022 Changes in this version + const DefaultLeaseDuration + const DefaultLeaseRenewalInterval + type Checkpointer interface + DeleteCheckpoint func(ctx context.Context, partitionID string) error + EnsureCheckpoint func(ctx context.Context, partitionID string) (persist.Checkpoint, error) + GetCheckpoint func(ctx context.Context, partitionID string) (persist.Checkpoint, bool) + UpdateCheckpoint func(ctx context.Context, partitionID string, checkpoint persist.Checkpoint) error + type EventProcessHostSetter interface + SetEventHostProcessor func(eph *EventProcessorHost) + type EventProcessorHost struct + func New(ctx context.Context, namespace, hubName string, ...) (*EventProcessorHost, error) + func NewFromConnectionString(ctx context.Context, connStr string, leaser Leaser, checkpointer Checkpointer, ...) (*EventProcessorHost, error) + func (h *EventProcessorHost) Close(ctx context.Context) error + func (h *EventProcessorHost) GetName() string + func (h *EventProcessorHost) GetPartitionIDs() []string + func (h *EventProcessorHost) PartitionIDsBeingProcessed() []string + func (h *EventProcessorHost) RegisterHandler(ctx context.Context, handler eventhub.Handler) (HandlerID, error) + func (h *EventProcessorHost) RegisteredHandlerIDs() []HandlerID + func (h *EventProcessorHost) Start(ctx context.Context) error + func (h *EventProcessorHost) StartNonBlocking(ctx context.Context) error + func (h *EventProcessorHost) UnregisterHandler(ctx context.Context, id HandlerID) + type EventProcessorHostOption func(host *EventProcessorHost) error + func WithConsumerGroup(consumerGroup string) EventProcessorHostOption + func WithEnvironment(env azure.Environment) EventProcessorHostOption + func WithNoBanner() EventProcessorHostOption + func WithWebSocketConnection() EventProcessorHostOption + type HandlerID string + type Lease struct + Epoch int64 + Owner string + PartitionID string + func (l *Lease) GetEpoch() int64 + func (l *Lease) GetOwner() string + func (l *Lease) GetPartitionID() string + func (l *Lease) IncrementEpoch() int64 + func (l *Lease) String() string + type LeaseMarker interface + GetEpoch func() int64 + GetOwner func() string + GetPartitionID func() string + IncrementEpoch func() int64 + IsExpired func(context.Context) bool + String func() string + type Leaser interface + AcquireLease func(ctx context.Context, partitionID string) (LeaseMarker, bool, error) + DeleteLease func(ctx context.Context, partitionID string) error + EnsureLease func(ctx context.Context, partitionID string) (LeaseMarker, error) + GetLeases func(ctx context.Context) ([]LeaseMarker, error) + ReleaseLease func(ctx context.Context, partitionID string) (bool, error) + RenewLease func(ctx context.Context, partitionID string) (LeaseMarker, bool, error) + UpdateLease func(ctx context.Context, partitionID string) (LeaseMarker, bool, error) + type Receiver interface + Receive func(ctx context.Context, handler eventhub.Handler) (close func() error, err error) + type StoreProvisioner interface + DeleteStore func(ctx context.Context) error + EnsureStore func(ctx context.Context) error + StoreExists func(ctx context.Context) (bool, error)