Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Batch ¶
type Batch struct { Signals []BatchSignal OnSignal func(sig BatchSignal) // contains filtered or unexported fields }
func (*Batch) CancelledEvents ¶
func (*Batch) RetryEvents ¶
type BatchSignal ¶
type BatchSignal struct { Tag BatchSignalTag Events []publisher.Event }
type BatchSignalTag ¶
type BatchSignalTag uint8
const ( BatchACK BatchSignalTag = iota BatchDrop BatchRetry BatchRetryEvents BatchCancelled BatchCancelledEvents )
Click to show internal directories.
Click to hide internal directories.