collector

Documentation

Index

• type Accumulator
  • func NewAccumulator(interval time.Duration) *Accumulator
  • func NewAccumulatorAt(interval time.Duration, origin time.Time) *Accumulator
  • func (a *Accumulator) Observe(snapshot model.ThreadSnapshot) []model.IntervalReport
• type Collector
  • func New(b backend.Backend, pid int, interval, sampleInterval time.Duration) *Collector
  • func (c *Collector) Run(ctx context.Context, count int, emit func(model.IntervalReport) error) error
• type EventAccumulator
  • func NewEventAccumulator(interval time.Duration, initial model.ThreadSnapshot) *EventAccumulator
  • func (a *EventAccumulator) Advance(watermark time.Time, lostEventsTotal uint64) []model.IntervalReport
  • func (a *EventAccumulator) NextBoundary() time.Time
  • func (a *EventAccumulator) Observe(event model.SchedulerEvent)
  • func (a *EventAccumulator) Origin() time.Time
  • func (a *EventAccumulator) SetClockCalibrationUncertainty(uncertainty time.Duration)

Types

type Accumulator

type Accumulator struct {
	// contains filtered or unexported fields
}

func NewAccumulator

func NewAccumulator(interval time.Duration) *Accumulator

func NewAccumulatorAt

func NewAccumulatorAt(interval time.Duration, origin time.Time) *Accumulator

NewAccumulatorAt aligns snapshot-derived counter windows with an external event timeline. The first snapshot still establishes the counter baseline, so time before that snapshot remains unobserved for cumulative counters.

func (*Accumulator) Observe

func (a *Accumulator) Observe(snapshot model.ThreadSnapshot) []model.IntervalReport

type Collector

type Collector struct {
	// contains filtered or unexported fields
}

func New

func New(b backend.Backend, pid int, interval, sampleInterval time.Duration) *Collector

func (*Collector) Run

func (c *Collector) Run(ctx context.Context, count int, emit func(model.IntervalReport) error) error

type EventAccumulator

type EventAccumulator struct {
	// contains filtered or unexported fields
}

func NewEventAccumulator

func NewEventAccumulator(interval time.Duration, initial model.ThreadSnapshot) *EventAccumulator

func (*EventAccumulator) Advance

func (a *EventAccumulator) Advance(watermark time.Time, lostEventsTotal uint64) []model.IntervalReport

func (*EventAccumulator) NextBoundary

func (a *EventAccumulator) NextBoundary() time.Time

func (*EventAccumulator) Observe

func (a *EventAccumulator) Observe(event model.SchedulerEvent)

func (*EventAccumulator) Origin

func (a *EventAccumulator) Origin() time.Time

func (*EventAccumulator) SetClockCalibrationUncertainty

func (a *EventAccumulator) SetClockCalibrationUncertainty(uncertainty time.Duration)