Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broadcaster ¶
type Broadcaster[T any] struct { // contains filtered or unexported fields }
func NewBroadcaster ¶
func NewBroadcaster[T any](name string) *Broadcaster[T]
func (*Broadcaster[T]) Broadcast ¶
func (b *Broadcaster[T]) Broadcast(msg T)
func (*Broadcaster[T]) Subscribe ¶
func (b *Broadcaster[T]) Subscribe() chan T
func (*Broadcaster[T]) Unsubscribe ¶
func (b *Broadcaster[T]) Unsubscribe(ch chan T)
type Listener ¶
type Listener[T any] struct { // contains filtered or unexported fields }
func NewListener ¶
func NewListener[T any](broadcaster *Broadcaster[T]) (*Listener[T], error)
func (*Listener[T]) WaitForNotificationsProcessed ¶
func (l *Listener[T]) WaitForNotificationsProcessed()
type Runner ¶
type Runner struct {
Options *model.Options
Task interface{}
Parameters model.Parameters
// Result channel to return results
ResultsChannel chan []interface{}
ErrorChannel chan error
// contains filtered or unexported fields
}
type Scheduler ¶
type Scheduler struct {
Task interface{}
Parameters model.Parameters
StartTime *time.Time
}
func NewScheduler ¶
Source Files
Click to show internal directories.
Click to hide internal directories.