Documentation
¶
Index ¶
- Variables
- func NewConcurrent(maxConcurrency int, next servicebus.Handler) servicebus.Handler
- func NewDeadlineContext(next servicebus.Handler) servicebus.Handler
- func NewPeekLockRenewer(interval *time.Duration, lockrenewer LockRenewer, next servicebus.Handler) servicebus.Handler
- func NewShuttleAdapter(next message.Handler) servicebus.Handler
- type EntityInfoProvider
- type LockRenewer
Constants ¶
This section is empty.
Variables ¶
View Source
var NextHandlerNilError error = fmt.Errorf("next handler cannot be nil")
Functions ¶
func NewConcurrent ¶
func NewConcurrent(maxConcurrency int, next servicebus.Handler) servicebus.Handler
func NewDeadlineContext ¶
func NewDeadlineContext(next servicebus.Handler) servicebus.Handler
func NewPeekLockRenewer ¶
func NewPeekLockRenewer(interval *time.Duration, lockrenewer LockRenewer, next servicebus.Handler) servicebus.Handler
func NewShuttleAdapter ¶
func NewShuttleAdapter(next message.Handler) servicebus.Handler
Types ¶
type EntityInfoProvider ¶
type EntityInfoProvider interface {
servicebus.EntityManagementAddresser
}
type LockRenewer ¶
type LockRenewer interface {
RenewLocks(ctx context.Context, messages ...*servicebus.Message) error
}
LockRenewer abstracts the servicebus subscription client where this functionality lives
Source Files
Click to show internal directories.
Click to hide internal directories.