Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecDetails ¶
type ExecDetails struct {
ProcessTime time.Duration
WaitTime time.Duration
BackoffTime time.Duration
RequestCount int
TotalKeys int64
ProcessedKeys int64
}
ExecDetails contains execution detail information.
func (ExecDetails) String ¶
func (d ExecDetails) String() string
String implements the fmt.Stringer interface.
type RuntimeStats ¶
type RuntimeStats struct {
// contains filtered or unexported fields
}
RuntimeStats collects one executor's execution info.
func (*RuntimeStats) Record ¶
func (e *RuntimeStats) Record(d time.Duration, rowNum int)
Record records executor's execution.
func (*RuntimeStats) String ¶
func (e *RuntimeStats) String() string
type RuntimeStatsColl ¶
type RuntimeStatsColl struct {
// contains filtered or unexported fields
}
RuntimeStatsColl collects executors's execution info.
func NewRuntimeStatsColl ¶
func NewRuntimeStatsColl() *RuntimeStatsColl
NewRuntimeStatsColl creates new executor collector.
func (*RuntimeStatsColl) Get ¶
func (e *RuntimeStatsColl) Get(planID string) *RuntimeStats
Get gets execStat for a executor.
Click to show internal directories.
Click to hide internal directories.