Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGRPCServer ¶ added in v1.1.0
NewGRPCServer creates a new grpc server instance.
func NewHTTPServer ¶ added in v1.1.0
NewHttpServer creates a new http server instance.
Types ¶
type Aggregator ¶ added in v1.1.7
type Aggregator struct {
// contains filtered or unexported fields
}
Aggregator define engine with name.
func New ¶ added in v1.1.3
func New() *Aggregator
New creates a new Aggregator instance with default name.
func NewAggregator ¶ added in v1.1.7
func NewAggregator(name string) *Aggregator
NewAggregator creates a new named aggregator.
func (*Aggregator) Aggregate ¶ added in v1.1.7
func (engine *Aggregator) Aggregate(runner ...runtime.Runnable) *Aggregator
Aggregate aggregates some runner
func (*Aggregator) Run ¶ added in v1.1.7
func (engine *Aggregator) Run(stopCh <-chan struct{})
Run runs the engine with blocking mode.
Click to show internal directories.
Click to hide internal directories.