interpolators

Documentation

Index

• Variables
• func Register()

Variables

var Closest = &datasets.Interpolator{
	Name:        "closest",
	Description: "Returns the datapoint with the closest timestamp to the reference timestamp",
	Constructor: func(name string, options map[string]interface{}, reference *pipescript.BufferIterator, stream pipescript.Iterator) (pipescript.Iterator, error) {
		dp1, err := stream.Next(&pipescript.Datapoint{})
		if err != nil || dp1 == nil {
			return pipescript.EmptyIterator{}, nil
		}
		dp2, err := stream.Next(&pipescript.Datapoint{})
		return &closestInterpolator{
			reference: reference,
			stream:    stream,
			prev:      dp1,
			next:      dp2,
		}, err
	},
}

Functions

func Register

func Register()