Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Aggregator ¶ added in v1.2.1
type Aggregator struct {
// contains filtered or unexported fields
}
Aggregator define engine with name.
func NewAggregator ¶ added in v1.2.1
func NewAggregator(name string) *Aggregator
NewAggregator creates a new named aggregator.
func (*Aggregator) Aggregate ¶ added in v1.2.1
func (engine *Aggregator) Aggregate(runner ...runtime.Runnable) *Aggregator
Aggregate aggregates some runner
func (*Aggregator) Run ¶ added in v1.2.1
func (engine *Aggregator) Run(stopCh <-chan struct{})
Run runs the engine with blocking mode.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.