gm

package
v1.0.23 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 23, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GlobalPercentileSamplesSize      = 254
	ThreadLocalPercentileSamplesSize = 30
)
View Source 
const (
	FlagQuoteVector = true
)
View Source 
const (
	NumIntervals = 32
)
View Source 
const (
	SeriesSize = 60 + 60 + 24 + 30
)

Variables

This section is empty.

Functions

func AddSampler 

func AddSampler(s sampler) disposer

func DescribeVarSeries 

func DescribeVarSeries(varName string, w io.StringWriter, option SeriesOption) error

func DescribeVarSeriesSafe 

func DescribeVarSeriesSafe(varName string, w io.StringWriter, option SeriesOption) error

func DisableInternalVariables 

func DisableInternalVariables()

func DisableServer added in v1.0.21 

func DisableServer()

func DivideToSlice 

func DivideToSlice(v Value) []int32

func DivideToSliceU32 

func DivideToSliceU32(v Value) []uint32

func Dump 

func Dump(dumper Dumper, option *DumpOption) (int, error)

func EnableInternalVariables 

func EnableInternalVariables()

func EnableServer added in v1.0.21 

func EnableServer()

func MakeSureEmpty 

func MakeSureEmpty()

func PushStub 

func PushStub(s stub, force bool) bool

func RemoteCall 

func RemoteCall(call func())

func RemoveVariable 

func RemoveVariable(id Identity)

func ServerEnabled added in v1.0.21 

func ServerEnabled() bool

Types

type Adder 

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

func NewAdder 

func NewAdder(name string) (*Adder, error)

func NewAdderNoExpose 

func NewAdderNoExpose() (*Adder, error)

func (*Adder) Describe 

func (a *Adder) Describe(w io.StringWriter, _ bool)

func (*Adder) DescribeSeries 

func (a *Adder) DescribeSeries(w io.StringWriter, opt *SeriesOption) error

func (*Adder) Dispose 

func (a *Adder) Dispose()

func (*Adder) GetValue 

func (a *Adder) GetValue() int64

func (*Adder) Push 

func (a *Adder) Push(v Mark)

func (*Adder) VarBase 

func (a *Adder) VarBase() *VarBase

type CDF 

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

func NewCDF 

func NewCDF(prefix, name string, filter DisplayFilter, w *PercentileWindow) (*CDF, error)

func NewCDFNoExpose 

func NewCDFNoExpose(w *PercentileWindow) (*CDF, error)

func NewCDFWithName 

func NewCDFWithName(name string, w *PercentileWindow) (*CDF, error)

func (*CDF) Describe 

func (c *CDF) Describe(w io.StringWriter, _ bool)

func (*CDF) DescribeSeries 

func (c *CDF) DescribeSeries(w io.StringWriter, opt *SeriesOption) error

func (*CDF) Dispose 

func (c *CDF) Dispose()

func (*CDF) Push 

func (c *CDF) Push(_ Mark)

func (*CDF) VarBase 

func (c *CDF) VarBase() *VarBase

type DisplayFilter 

type DisplayFilter int
const (
	DisplayOnNothing DisplayFilter = iota
	DisplayOnHTML
	DisplayOnPlainText
	DisplayOnAll
)

type DumpOption 

type DumpOption struct {
	QuoteString    bool
	QuestionMark   byte
	DisplayFilter  DisplayFilter
	WhiteWildcards string
	BlackWildcards string
}

type Dumper 

type Dumper interface {
	Dump(name, desc string) bool
}

type Identity 

type Identity uint32

func (Identity) Cancel 

func (i Identity) Cancel()

func (Identity) ForceMark added in v1.0.23 

func (i Identity) ForceMark(n int32, force bool) bool

func (Identity) Mark 

func (i Identity) Mark(n int32) bool

type IntRecorder 

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

func NewIntRecorder 

func NewIntRecorder(prefix, name string, filter DisplayFilter) (*IntRecorder, error)

func NewIntRecorderNoExpose 

func NewIntRecorderNoExpose() (*IntRecorder, error)

func NewIntRecorderWithName 

func NewIntRecorderWithName(name string) (*IntRecorder, error)

func (*IntRecorder) Describe 

func (ir *IntRecorder) Describe(w io.StringWriter, _ bool)

func (*IntRecorder) DescribeSeries 

func (ir *IntRecorder) DescribeSeries(_ io.StringWriter, _ *SeriesOption) error

func (*IntRecorder) Dispose 

func (ir *IntRecorder) Dispose()

func (*IntRecorder) FloatAverage 

func (ir *IntRecorder) FloatAverage() float64

func (*IntRecorder) GetValue 

func (ir *IntRecorder) GetValue() Value

func (*IntRecorder) GetWindowSampler 

func (ir *IntRecorder) GetWindowSampler() winSampler

func (*IntRecorder) IntAverage 

func (ir *IntRecorder) IntAverage() int64

func (*IntRecorder) Operators 

func (ir *IntRecorder) Operators() (op Operator, invOp Operator)

func (*IntRecorder) Push 

func (ir *IntRecorder) Push(v Mark)

func (*IntRecorder) Reset 

func (ir *IntRecorder) Reset() Value

func (*IntRecorder) VarBase 

func (ir *IntRecorder) VarBase() *VarBase

type IntSeries 

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

func NewIntSeries 

func NewIntSeries(op Operator, divOp OperatorInt) *IntSeries

func (*IntSeries) Append 

func (s *IntSeries) Append(v Value)

func (*IntSeries) Describe 

func (s *IntSeries) Describe(w io.StringWriter, splitName []string, cvt ValueConverter)

func (*IntSeries) GetTrend 

func (s *IntSeries) GetTrend() *Trend

type LatencyRecorder 

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

func NewLatencyRecorder 

func NewLatencyRecorder(name string) (*LatencyRecorder, error)

func NewLatencyRecorderInWindow 

func NewLatencyRecorderInWindow(name string, window int) (*LatencyRecorder, error)

func (*LatencyRecorder) Count 

func (lr *LatencyRecorder) Count() int64

func (*LatencyRecorder) CountName 

func (lr *LatencyRecorder) CountName() string

func (*LatencyRecorder) Describe 

func (lr *LatencyRecorder) Describe(_ io.StringWriter, _ bool)

func (*LatencyRecorder) DescribeSeries 

func (lr *LatencyRecorder) DescribeSeries(_ io.StringWriter, _ *SeriesOption) error

func (*LatencyRecorder) Dispose 

func (lr *LatencyRecorder) Dispose()

func (*LatencyRecorder) Latency 

func (lr *LatencyRecorder) Latency() int64

func (*LatencyRecorder) LatencyCDFName 

func (lr *LatencyRecorder) LatencyCDFName() string

func (*LatencyRecorder) LatencyIn 

func (lr *LatencyRecorder) LatencyIn(window int) int64

func (*LatencyRecorder) LatencyName 

func (lr *LatencyRecorder) LatencyName() string

func (*LatencyRecorder) LatencyPercentile 

func (lr *LatencyRecorder) LatencyPercentile(ratio float64) int64

func (*LatencyRecorder) LatencyPercentiles 

func (lr *LatencyRecorder) LatencyPercentiles() []uint32

func (*LatencyRecorder) LatencyPercentilesName 

func (lr *LatencyRecorder) LatencyPercentilesName() string

func (*LatencyRecorder) MaxLatency 

func (lr *LatencyRecorder) MaxLatency() int64

func (*LatencyRecorder) MaxLatencyName 

func (lr *LatencyRecorder) MaxLatencyName() string

func (*LatencyRecorder) Push 

func (lr *LatencyRecorder) Push(v Mark)

func (*LatencyRecorder) Qps 

func (lr *LatencyRecorder) Qps() int64

func (*LatencyRecorder) QpsIn 

func (lr *LatencyRecorder) QpsIn(window int) int64

func (*LatencyRecorder) QpsName 

func (lr *LatencyRecorder) QpsName() string

func (*LatencyRecorder) VarBase 

func (lr *LatencyRecorder) VarBase() *VarBase

func (*LatencyRecorder) WindowSize 

func (lr *LatencyRecorder) WindowSize() int

type Mark 

type Mark int32

type Maxer 

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

func NewMaxer 

func NewMaxer(name string) (*Maxer, error)

NewMaxer create an maxer

func NewMaxerNoExpose 

func NewMaxerNoExpose() (*Maxer, error)

func (*Maxer) Describe 

func (m *Maxer) Describe(w io.StringWriter, quote bool)

func (*Maxer) DescribeSeries 

func (m *Maxer) DescribeSeries(w io.StringWriter, opt *SeriesOption) error

func (*Maxer) Dispose 

func (m *Maxer) Dispose()

func (*Maxer) Push 

func (m *Maxer) Push(v Mark)

func (*Maxer) VarBase 

func (m *Maxer) VarBase() *VarBase

type Operator 

type Operator func(left, right Value) Value

type OperatorInt 

type OperatorInt func(left Value, right int) Value

type PassiveCallback 

type PassiveCallback func() Value

type PassiveStatus 

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

func NewCounter 

func NewCounter(prefix, name string, filter DisplayFilter) (*PassiveStatus, error)

func NewCounterNoExpose 

func NewCounterNoExpose() (*PassiveStatus, error)

func NewCounterWithName 

func NewCounterWithName(name string) (*PassiveStatus, error)

func NewPassiveStatus 

func NewPassiveStatus(prefix, name string, filter DisplayFilter,
	callback PassiveCallback, op, invOp Operator, divOp OperatorInt) (*PassiveStatus, error)

func NewPassiveStatusNoExpose 

func NewPassiveStatusNoExpose(callback PassiveCallback, op, invOp Operator) (*PassiveStatus, error)

func NewPassiveStatusWithName 

func NewPassiveStatusWithName(name string, callback PassiveCallback, op, invOp Operator, divOp OperatorInt) (*PassiveStatus, error)

func NewQPS 

func NewQPS(name string) (*PassiveStatus, error)

func NewQPSNoExpose 

func NewQPSNoExpose() (*PassiveStatus, error)

func (*PassiveStatus) Describe 

func (p *PassiveStatus) Describe(w io.StringWriter, _ bool)

func (*PassiveStatus) DescribeSeries 

func (p *PassiveStatus) DescribeSeries(w io.StringWriter, opt *SeriesOption) error

func (*PassiveStatus) Dispose 

func (p *PassiveStatus) Dispose()

func (*PassiveStatus) GetValue 

func (p *PassiveStatus) GetValue() Value

func (*PassiveStatus) GetWindowSampler 

func (p *PassiveStatus) GetWindowSampler() winSampler

func (*PassiveStatus) Operators 

func (p *PassiveStatus) Operators() (op Operator, invOp Operator)

func (*PassiveStatus) Push 

func (p *PassiveStatus) Push(v Mark)

func (*PassiveStatus) Reset 

func (p *PassiveStatus) Reset() Value

func (*PassiveStatus) SetDescriber 

func (p *PassiveStatus) SetDescriber(serial ValueSerializer, cvt ValueConverter)

func (*PassiveStatus) SetVectorNames 

func (p *PassiveStatus) SetVectorNames(names []string)

func (*PassiveStatus) VarBase 

func (p *PassiveStatus) VarBase() *VarBase

type Percentile 

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

func NewPercentile 

func NewPercentile() *Percentile

func (*Percentile) Dispose 

func (p *Percentile) Dispose()

func (*Percentile) GetValue 

func (p *Percentile) GetValue() *PercentileSamples

func (*Percentile) GetWindowSampler 

func (p *Percentile) GetWindowSampler() PercentileWinSampler

func (*Percentile) Operators 

func (p *Percentile) Operators() (op PercentileOperator, invOp PercentileOperator)

func (*Percentile) Push 

func (p *Percentile) Push(v Mark)

func (*Percentile) Reset 

func (p *Percentile) Reset() *PercentileSamples

type PercentileInterval 

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

func (*PercentileInterval) Add32 

func (pi *PercentileInterval) Add32(x uint32) bool

func (*PercentileInterval) Add64 

func (pi *PercentileInterval) Add64(x int64) bool

func (*PercentileInterval) AddedCount 

func (pi *PercentileInterval) AddedCount() uint32

func (*PercentileInterval) Clear 

func (pi *PercentileInterval) Clear()

func (*PercentileInterval) CopyFrom 

func (pi *PercentileInterval) CopyFrom(rhs *PercentileInterval)

func (*PercentileInterval) Describe 

func (pi *PercentileInterval) Describe(w io.StringWriter)

func (pi *PercentileInterval) check() bool { 

	n := pi.samples[0]
	for i := 1; i < int(pi.numSamples); i++ {
		if pi.samples[i] != n+uint32(i) {
			return false
		}
	}
	return true
}

func (*PercentileInterval) Empty 

func (pi *PercentileInterval) Empty() bool

func (*PercentileInterval) Full 

func (pi *PercentileInterval) Full() bool

func (*PercentileInterval) Merge 

func (pi *PercentileInterval) Merge(rhs *PercentileInterval)

func (*PercentileInterval) MergeWithExpectation 

func (pi *PercentileInterval) MergeWithExpectation(rhs *PercentileInterval, n uint16)

func (*PercentileInterval) SameOf 

func (pi *PercentileInterval) SameOf(rhs *PercentileInterval) bool

func (*PercentileInterval) SampleAt 

func (pi *PercentileInterval) SampleAt(idx int) uint32

func (*PercentileInterval) SampleCount 

func (pi *PercentileInterval) SampleCount() uint16

type PercentileOperator 

type PercentileOperator func(left, right *PercentileSamples)

type PercentileOperatorInt 

type PercentileOperatorInt func(left *PercentileSamples, right int)

type PercentileReducer 

type PercentileReducer interface {
	Reset() *PercentileSamples
	GetValue() *PercentileSamples
	Operators() (op PercentileOperator, invOp PercentileOperator)
}

type PercentileReducerSampler 

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

func NewPercentileReducerSampler 

func NewPercentileReducerSampler(r PercentileReducer) *PercentileReducerSampler

func (*PercentileReducerSampler) Dispose 

func (rs *PercentileReducerSampler) Dispose()

func (*PercentileReducerSampler) SamplesInWindow 

func (rs *PercentileReducerSampler) SamplesInWindow(window int) (ret []*PercentileSamples)

func (*PercentileReducerSampler) SetWindow 

func (rs *PercentileReducerSampler) SetWindow(window int)

func (*PercentileReducerSampler) ValueInWindow 

func (rs *PercentileReducerSampler) ValueInWindow(window int) PercentileSampleInRange

type PercentileSample 

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

type PercentileSampleInRange 

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

type PercentileSampleQueue 

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

type PercentileSamples 

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

func NewPercentileSamples 

func NewPercentileSamples(sampleSize int) *PercentileSamples

func (*PercentileSamples) Clear 

func (ps *PercentileSamples) Clear()

func (*PercentileSamples) CombineOf 

func (ps *PercentileSamples) CombineOf(many []*PercentileSamples)

func (*PercentileSamples) CopyFrom 

func (ps *PercentileSamples) CopyFrom(rhs *PercentileSamples)

func (*PercentileSamples) Describe 

func (ps *PercentileSamples) Describe(w io.StringWriter)

func (*PercentileSamples) Dup 

func (ps *PercentileSamples) Dup() *PercentileSamples

func (*PercentileSamples) DupFrom 

func (ps *PercentileSamples) DupFrom(rhs *PercentileSamples)

func (*PercentileSamples) GetNumber 

func (ps *PercentileSamples) GetNumber(ratio float64) uint32

func (*PercentileSamples) IntervalOf 

func (ps *PercentileSamples) IntervalOf(idx int) *PercentileInterval

func (*PercentileSamples) Merge 

func (ps *PercentileSamples) Merge(rhs *PercentileSamples)

func (*PercentileSamples) TakeFrom 

func (ps *PercentileSamples) TakeFrom(rhs *PercentileSamples)

type PercentileSeries 

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

func NewPercentileSeries 

func NewPercentileSeries(op PercentileOperator, divOp PercentileOperatorInt) *PercentileSeries

func (*PercentileSeries) Append 

func (s *PercentileSeries) Append(v *PercentileSamples)

type PercentileTrend 

type PercentileTrend struct {
	Label string                 `json:"label"`
	Data  [][]*PercentileSamples `json:"data"`
}

type PercentileWinSampler 

type PercentileWinSampler interface {
	SetWindow(window int)
	SamplesInWindow(window int) []*PercentileSamples
	ValueInWindow(window int) PercentileSampleInRange
}

type PercentileWindow 

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

func NewPercentileWindow 

func NewPercentileWindow(prefix, name string, filter DisplayFilter,
	window int, sampler PercentileWinSampler, freq SeriesFrequency, op PercentileOperator, seriesDivOp PercentileOperatorInt) (*PercentileWindow, error)

func NewPercentileWindowNoExpose 

func NewPercentileWindowNoExpose(window int, sampler PercentileWinSampler, op PercentileOperator) (*PercentileWindow, error)

func NewPercentileWindowWithName 

func NewPercentileWindowWithName(name string, window int, sampler PercentileWinSampler, op PercentileOperator, seriesDivOp PercentileOperatorInt) (*PercentileWindow, error)

func (*PercentileWindow) Describe 

func (w *PercentileWindow) Describe(sw io.StringWriter, _ bool)

func (*PercentileWindow) DescribeSeries 

func (w *PercentileWindow) DescribeSeries(sw io.StringWriter, opt *SeriesOption) error

func (*PercentileWindow) Dispose 

func (w *PercentileWindow) Dispose()

func (*PercentileWindow) GetSamples 

func (w *PercentileWindow) GetSamples() []*PercentileSamples

func (*PercentileWindow) GetSpan 

func (w *PercentileWindow) GetSpan() PercentileSampleInRange

func (*PercentileWindow) GetSpanOf 

func (w *PercentileWindow) GetSpanOf(window int) PercentileSampleInRange

func (*PercentileWindow) Push 

func (w *PercentileWindow) Push(v Mark)

func (*PercentileWindow) Value 

func (w *PercentileWindow) Value() *PercentileSamples

func (*PercentileWindow) ValueOf 

func (w *PercentileWindow) ValueOf(window int) *PercentileSamples

func (*PercentileWindow) VarBase 

func (w *PercentileWindow) VarBase() *VarBase

func (*PercentileWindow) WindowSize 

func (w *PercentileWindow) WindowSize() int

type Pushable 

type Pushable interface {
	Push(v Mark)
}

type Reducer 

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

func NewReducer 

func NewReducer(op, invOp Operator, seriesDivOp OperatorInt) *Reducer

func (*Reducer) Describe 

func (r *Reducer) Describe(w io.StringWriter, serial func(v Value) string)

func (*Reducer) DescribeSeries 

func (r *Reducer) DescribeSeries(w io.StringWriter, opt *SeriesOption, splitName []string, cvt ValueConverter) error

func (*Reducer) Dispose 

func (r *Reducer) Dispose()

func (*Reducer) GetValue 

func (r *Reducer) GetValue() Value

func (*Reducer) GetWindowSampler 

func (r *Reducer) GetWindowSampler() winSampler

func (*Reducer) OnExpose 

func (r *Reducer) OnExpose()

func (*Reducer) Operators 

func (r *Reducer) Operators() (op Operator, invOp Operator)

func (*Reducer) Push 

func (r *Reducer) Push(v Mark)

func (*Reducer) Reset 

func (r *Reducer) Reset() Value

type ReducerSampler 

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

func NewReducerSampler 

func NewReducerSampler(r reduceable) *ReducerSampler

func (*ReducerSampler) SamplesInWindow 

func (rs *ReducerSampler) SamplesInWindow(window int) (ret []Value)

func (*ReducerSampler) SetWindow 

func (rs *ReducerSampler) SetWindow(window int)

func (*ReducerSampler) ValueInWindow 

func (rs *ReducerSampler) ValueInWindow(window int) sampleInRange

type SeriesFrequency 

type SeriesFrequency int
const (
	SeriesInWindow SeriesFrequency = iota
	SeriesInSecond
)

type SeriesOption 

type SeriesOption struct {
	FixedLength, TestOnly bool
}

func NewSeriesOption 

func NewSeriesOption() *SeriesOption

type Status 

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

func NewStatus 

func NewStatus(name string) (*Status, error)

func (*Status) Describe 

func (a *Status) Describe(w io.StringWriter, _ bool)

func (*Status) DescribeSeries 

func (a *Status) DescribeSeries(_ io.StringWriter, _ *SeriesOption) error

func (*Status) Dispose 

func (a *Status) Dispose()

func (*Status) GetValue 

func (a *Status) GetValue() int64

func (*Status) Push 

func (a *Status) Push(v Mark)

func (*Status) VarBase 

func (a *Status) VarBase() *VarBase

type Trend 

type Trend struct {
	Label string  `json:"label"`
	Data  []Value `json:"data"`
}

type UIntSlice 

type UIntSlice []uint32

IntSlice attaches the methods of Interface to []int, sorting in increasing order.

func (UIntSlice) Len 

func (p UIntSlice) Len() int

func (UIntSlice) Less 

func (p UIntSlice) Less(i, j int) bool

func (UIntSlice) Swap 

func (p UIntSlice) Swap(i, j int)

type Value 

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

func CombineToValue 

func CombineToValue(s []int64) Value

func CombineToValueU32 

func CombineToValueU32(s []uint32) Value

func OneValue 

func OneValue(x int64) Value

func ValueOf 

func ValueOf(x, y int64) Value

func (*Value) Add 

func (v *Value) Add(rhs *Value) Value

func (*Value) Append 

func (v *Value) Append(rhs *Value)

func (*Value) AverageFloat 

func (v *Value) AverageFloat() float64

func (*Value) AverageInt 

func (v *Value) AverageInt() int64

func (*Value) GetU32 

func (v *Value) GetU32(idx int) uint32

func (*Value) Reduce 

func (v *Value) Reduce(rhs *Value)

func (*Value) Reset 

func (v *Value) Reset()

func (*Value) SetU32 

func (v *Value) SetU32(idx int, val uint32)

func (*Value) Sub 

func (v *Value) Sub(rhs *Value) Value

type ValueConverter 

type ValueConverter func(v Value, idx int) string

type ValueSerializer 

type ValueSerializer func(v Value) string
var VectorValueSerializer ValueSerializer = func(v Value) string {
	slice := DivideToSliceU32(v)
	quote := ""
	if FlagQuoteVector {
		quote = "\""
	}
	return fmt.Sprintf("%s[%d,%d,%d,%d]%s", quote, slice[0], slice[1], slice[2], slice[3], quote)
}
var XValueSerializer ValueSerializer = func(v Value) string {
	return strconv.Itoa(int(v.x))
}
var YValueSerializer ValueSerializer = func(v Value) string {
	return strconv.Itoa(int(v.y))
}

type VarBase 

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

func Expose 

func Expose(prefix, name string, displayFilter DisplayFilter, v Variable) (*VarBase, error)

func (*VarBase) AddChild 

func (vb *VarBase) AddChild(id ...Identity)

func (*VarBase) AddDisposer 

func (vb *VarBase) AddDisposer(d disposer)

func (*VarBase) Cancel 

func (vb *VarBase) Cancel()

func (*VarBase) EnablePerf 

func (vb *VarBase) EnablePerf()

func (*VarBase) ForceMark added in v1.0.23 

func (vb *VarBase) ForceMark(n int32, force bool) bool

func (*VarBase) GetDisplayFilter 

func (vb *VarBase) GetDisplayFilter() DisplayFilter

func (*VarBase) ID 

func (vb *VarBase) ID() Identity

func (*VarBase) Mark 

func (vb *VarBase) Mark(n int32) bool

func (*VarBase) Marker 

func (vb *VarBase) Marker() gmi.Marker

func (*VarBase) Name 

func (vb *VarBase) Name() string

func (*VarBase) Valid 

func (vb *VarBase) Valid() bool

type Variable 

type Variable interface {
	VarBase() *VarBase
	// Called internally inside server's routine to mark variable
	Push(v Mark)
	// Notify variable to dispose, and return all child variables that need to be removed
	Dispose()
	Describe(w io.StringWriter, quote bool)
	DescribeSeries(w io.StringWriter, opt *SeriesOption) error
}

type Window 

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

func NewAdderPersecond 

func NewAdderPersecond(name string) (*Window, error)

func NewWindow 

func NewWindow(prefix, name string, filter DisplayFilter, window int,
	sampler winSampler, freq SeriesFrequency, op Operator, seriesDivOp OperatorInt) (*Window, error)

func NewWindowMaxer 

func NewWindowMaxer(name string) (*Window, error)

func NewWindowMaxerIn 

func NewWindowMaxerIn(name string, window int) (*Window, error)

func NewWindowNoExpose 

func NewWindowNoExpose(window int, sampler winSampler, op Operator) (*Window, error)

func NewWindowWithName 

func NewWindowWithName(name string, window int, sampler winSampler, op Operator, seriesDivOp OperatorInt) (*Window, error)

func (*Window) Describe 

func (w *Window) Describe(sw io.StringWriter, _ bool)

func (*Window) DescribeSeries 

func (w *Window) DescribeSeries(sw io.StringWriter, opt *SeriesOption) error

func (*Window) Dispose 

func (w *Window) Dispose()

func (*Window) GetSamples 

func (w *Window) GetSamples() []Value

func (*Window) GetSpan 

func (w *Window) GetSpan() sampleInRange

func (*Window) GetSpanOf 

func (w *Window) GetSpanOf(window int) sampleInRange

func (*Window) Push 

func (w *Window) Push(v Mark)

func (*Window) SetDescriber 

func (w *Window) SetDescriber(serial ValueSerializer, cvt ValueConverter)

func (*Window) SetReceiver 

func (w *Window) SetReceiver(receiver Pushable)

func (*Window) Value 

func (w *Window) Value() Value

func (*Window) ValueOf 

func (w *Window) ValueOf(window int) Value

func (*Window) VarBase 

func (w *Window) VarBase() *VarBase

func (*Window) WindowSize 

func (w *Window) WindowSize() int

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.