type golang.org/x/net/internal/timeseries.Observable
40 uses
golang.org/x/net/internal/timeseries (current package)
timeseries.go#L38: type Observable interface {
timeseries.go#L40: Add(other Observable) // Adds the data from a different observation to self
timeseries.go#L42: CopyFrom(other Observable) // Copies the contents of a given observation to self
timeseries.go#L49: func NewFloat() Observable {
timeseries.go#L62: func (f *Float) Add(other Observable) {
timeseries.go#L69: func (f *Float) CopyFrom(other Observable) {
timeseries.go#L93: buckets []Observable // collections of observations
timeseries.go#L94: provider func() Observable // used for creating new Observable
timeseries.go#L109: func (l *tsLevel) InitLevel(size time.Duration, numBuckets int, f func() Observable) {
timeseries.go#L112: l.buckets = make([]Observable, numBuckets)
timeseries.go#L124: provider func() Observable // make more Observable
timeseries.go#L128: total Observable // convenient aggregation of all Observable
timeseries.go#L130: pending Observable // observations not yet bucketed
timeseries.go#L136: func (ts *timeSeries) init(resolutions []time.Duration, f func() Observable, numBuckets int, clock Clock) {
timeseries.go#L169: func (ts *timeSeries) Add(observation Observable) {
timeseries.go#L174: func (ts *timeSeries) AddWithTime(observation Observable, t time.Time) {
timeseries.go#L200: func (ts *timeSeries) mergeValue(observation Observable, t time.Time) {
timeseries.go#L256: func (ts *timeSeries) Latest(level, num int) Observable {
timeseries.go#L282: func (ts *timeSeries) LatestBuckets(level, num int) []Observable {
timeseries.go#L292: results := make([]Observable, num)
timeseries.go#L333: func (ts *timeSeries) Range(start, finish time.Time) Observable {
timeseries.go#L338: func (ts *timeSeries) Recent(delta time.Duration) Observable {
timeseries.go#L344: func (ts *timeSeries) Total() Observable {
timeseries.go#L354: func (ts *timeSeries) ComputeRange(start, finish time.Time, num int) []Observable {
timeseries.go#L365: results := make([]Observable, num)
timeseries.go#L384: func (ts *timeSeries) RecentList(delta time.Duration, num int) []Observable {
timeseries.go#L394: func (ts *timeSeries) extract(l *tsLevel, start, finish time.Time, num int, results []Observable) {
timeseries.go#L459: func (ts *timeSeries) resetObservation(observation Observable) Observable {
timeseries.go#L474: func NewTimeSeries(f func() Observable) *TimeSeries {
timeseries.go#L480: func NewTimeSeriesWithClock(f func() Observable, clock Clock) *TimeSeries {
timeseries.go#L492: func NewMinuteHourSeries(f func() Observable) *MinuteHourSeries {
timeseries.go#L498: func NewMinuteHourSeriesWithClock(f func() Observable, clock Clock) *MinuteHourSeries {
timeseries.go#L505: func (ts *MinuteHourSeries) Minute() Observable {
timeseries.go#L509: func (ts *MinuteHourSeries) Hour() Observable {
golang.org/x/net/trace
histogram.go#L170: func (h *histogram) Add(other timeseries.Observable) {
histogram.go#L202: func (h *histogram) CopyFrom(other timeseries.Observable) {
histogram.go#L228: func (h *histogram) New() timeseries.Observable {
trace.go#L256: var obs timeseries.Observable
trace.go#L586: Latency: timeseries.NewMinuteHourSeries(func() timeseries.Observable { return new(histogram) }),