Documentation
¶
Index ¶
- func Add(param float64, input *oproto.ValueStream) *oproto.ValueStream
- func First(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
- func Interpolate(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
- func Last(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
- func Max(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
- func Mean(input *oproto.ValueStream) *oproto.ValueStream
- func Min(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
- func MovingAverage(window uint64, input *oproto.ValueStream) *oproto.ValueStream
- func Multiply(param float64, input *oproto.ValueStream) *oproto.ValueStream
- func Power(param float64, input *oproto.ValueStream) *oproto.ValueStream
- func Rate(input *oproto.ValueStream) *oproto.ValueStream
- func Root(param float64, input *oproto.ValueStream) *oproto.ValueStream
- func SignedRate(input *oproto.ValueStream) *oproto.ValueStream
- func SignedRateStream(input *oproto.ValueStream) *oproto.ValueStream
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Add ¶
func Add(param float64, input *oproto.ValueStream) *oproto.ValueStream
func First ¶
func First(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
func Interpolate ¶
func Interpolate(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
Interpolate takes a counter value sampled at variable intervals and aligns each value with a <duration> ms boundary. The initial value is not output unless it appears exactly on a ms boundary. Runs of two or more missing values will be filled by NaN
func Last ¶
func Last(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
func Max ¶
func Max(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
func Mean ¶
func Mean(input *oproto.ValueStream) *oproto.ValueStream
func Min ¶
func Min(duration uint64, input *oproto.ValueStream) *oproto.ValueStream
func MovingAverage ¶
func MovingAverage(window uint64, input *oproto.ValueStream) *oproto.ValueStream
func Multiply ¶
func Multiply(param float64, input *oproto.ValueStream) *oproto.ValueStream
func Power ¶
func Power(param float64, input *oproto.ValueStream) *oproto.ValueStream
func Rate ¶
func Rate(input *oproto.ValueStream) *oproto.ValueStream
func Root ¶
func Root(param float64, input *oproto.ValueStream) *oproto.ValueStream
func SignedRate ¶
func SignedRate(input *oproto.ValueStream) *oproto.ValueStream
func SignedRateStream ¶
func SignedRateStream(input *oproto.ValueStream) *oproto.ValueStream
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.