Documentation
¶
Index ¶
Constants ¶
View Source
const BatchTableSchedulerName = "batch-table-scheduler"
Variables ¶
View Source
var DefaultConfig = map[string]interface{}{
"nr-worker": 1,
"batch-size": 1,
"queue-size": 1024,
"sliding-window-size": 1024 * 10,
}
Functions ¶
This section is empty.
Types ¶
type BatchSchedulerConfig ¶
type BatchSchedulerConfig struct {
NrWorker int `mapstructure:"nr-worker"json:"nr-worker"`
MaxBatchPerWorker int `mapstructure:"batch-size"json:"batch-size"`
QueueSize int `mapstructure:"queue-size"json:"queue-size"`
SlidingWindowSize int `mapstructure:"sliding-window-size"json:"sliding-window-size"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.