eph

Sep 4, 2018

Changes in this version

type EventProcessorHost

+ func NewFromConnectionString(ctx context.Context, connStr string, leaser Leaser, checkpointer Checkpointer, ...) (*EventProcessorHost, error)

type EventProcessorHostOption

+ func WithEnvironment(env azure.Environment) EventProcessorHostOption

Jul 6, 2018

Changes in this version

type EventProcessorHost

+ func (h *EventProcessorHost) RegisterHandler(ctx context.Context, handler eventhub.Handler) (HandlerID, error)

+ func (h *EventProcessorHost) RegisteredHandlerIDs() []HandlerID

+ func (h *EventProcessorHost) UnregisterHandler(ctx context.Context, id HandlerID)

+ type HandlerID string

Apr 25, 2018

Changes in this version

type Lease

+ func (l *Lease) String() string

type LeaseMarker

+ String func() string

Apr 13, 2018

Changes in this version

type EventProcessorHostOption

+ func WithNoBanner() EventProcessorHostOption

Mar 23, 2018

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 (h *EventProcessorHost) Close() error

+ func (h *EventProcessorHost) GetName() string

+ func (h *EventProcessorHost) GetPartitionIDs() []string

+ func (h *EventProcessorHost) PartitionIDsBeingProcessed() []string

+ func (h *EventProcessorHost) Receive(handler eventhub.Handler) (close func() error, err error)

+ func (h *EventProcessorHost) Start(ctx context.Context) error

+ func (h *EventProcessorHost) StartNonBlocking(ctx context.Context) error

+ type EventProcessorHostOption func(host *EventProcessorHost) error

+ 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

+ type LeaseMarker interface

+ GetEpoch func() int64

+ GetOwner func() string

+ GetPartitionID func() string

+ IncrementEpoch func() int64

+ IsExpired func(context.Context) bool

+ 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)