execdetails

Documentation

Index

• type ExecDetails
  • func (d ExecDetails) String() string
• type RuntimeStats
  • func (e *RuntimeStats) Record(d time.Duration, rowNum int)
  • func (e *RuntimeStats) String() string
• type RuntimeStatsColl
  • func NewRuntimeStatsColl() *RuntimeStatsColl
  • func (e *RuntimeStatsColl) Get(planID string) *RuntimeStats

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.