quantile

Documentation

Index

• type E2eProcessingLatencyAggregate
  • func (e *E2eProcessingLatencyAggregate) Add(e2 *E2eProcessingLatencyAggregate)
  • func (e *E2eProcessingLatencyAggregate) Len() int
  • func (e *E2eProcessingLatencyAggregate) Less(i, j int) bool
  • func (e *E2eProcessingLatencyAggregate) Swap(i, j int)
  • func (e *E2eProcessingLatencyAggregate) UnmarshalJSON(b []byte) error
• type Quantile
  • func New(WindowTime time.Duration, Percentiles []float64) *Quantile
  • func (q *Quantile) Insert(msgStartTime int64)
  • func (q *Quantile) IsDataStale(now time.Time) bool
  • func (q *Quantile) Merge(them *Quantile)
  • func (q *Quantile) QueryHandler() *quantile.Stream
  • func (q *Quantile) Result() *Result
• type Result
  • func (r *Result) String() string

Types

type E2eProcessingLatencyAggregate

type E2eProcessingLatencyAggregate struct {
	Count       int                  `json:"count"`
	Percentiles []map[string]float64 `json:"percentiles"`
	Topic       string               `json:"topic"`
	Channel     string               `json:"channel"`
	Addr        string               `json:"host"`
}

func (*E2eProcessingLatencyAggregate) Add

func (e *E2eProcessingLatencyAggregate) Add(e2 *E2eProcessingLatencyAggregate)

Add merges e2 into e by averaging the percentiles

func (*E2eProcessingLatencyAggregate) Len

func (e *E2eProcessingLatencyAggregate) Len() int

func (*E2eProcessingLatencyAggregate) Less

func (e *E2eProcessingLatencyAggregate) Less(i, j int) bool

func (*E2eProcessingLatencyAggregate) Swap

func (e *E2eProcessingLatencyAggregate) Swap(i, j int)

func (*E2eProcessingLatencyAggregate) UnmarshalJSON

func (e *E2eProcessingLatencyAggregate) UnmarshalJSON(b []byte) error

type Quantile

type Quantile struct {
	sync.Mutex

	Percentiles    []float64
	MoveWindowTime time.Duration
	// contains filtered or unexported fields
}

func New

func New(WindowTime time.Duration, Percentiles []float64) *Quantile

func (*Quantile) Insert

func (q *Quantile) Insert(msgStartTime int64)

func (*Quantile) IsDataStale

func (q *Quantile) IsDataStale(now time.Time) bool

func (*Quantile) Merge

func (q *Quantile) Merge(them *Quantile)

func (*Quantile) QueryHandler

func (q *Quantile) QueryHandler() *quantile.Stream

func (*Quantile) Result

func (q *Quantile) Result() *Result

type Result

type Result struct {
	Count       int                  `json:"count"`
	Percentiles []map[string]float64 `json:"percentiles"`
}

func (*Result) String

func (r *Result) String() string