Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // DefaultSendEventTimeout is the timeout used when publishing events to consumers DefaultSendEventTimeout = 2 * time.Second // ConsumerGCInterval is the interval at which garbage collection of consumers // occures ConsumerGCInterval = time.Minute )
Functions ¶
This section is empty.
Types ¶
type Eventer ¶
type Eventer struct {
// contains filtered or unexported fields
}
Eventer is a utility to control broadcast of TaskEvents to multiple consumers. It also implements the TaskEvents func in the DriverPlugin interface so that it can be embedded in a implementing driver struct.
func NewEventer ¶
NewEventer returns an Eventer with a running event loop that can be stopped by closing the given stop channel
Source Files
Click to show internal directories.
Click to hide internal directories.