Documentation ¶
Index ¶
- func BatchExec(ctx context.Context, taskGroup string, in ...Task) map[string]interface{}
- func Exec(ctx context.Context, taskGroup string, in Task) (interface{}, error)
- func RegisterTaskGroup(taskGroup string, method func(...Task) (map[string]interface{}, error), ...)
- type GroupTask
- type MergeTask
- type Option
- type Task
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Option ¶
type Option struct {
// contains filtered or unexported fields
}
func DefaultOption ¶
func DefaultOption() *Option
func (*Option) WithBatchSize ¶
func (*Option) WithMaxWoker ¶
func (*Option) WithTimeRange ¶ added in v0.2.21
ms
Click to show internal directories.
Click to hide internal directories.