Documentation
¶
Index ¶
- func FilterAndRank(in *model.ObsTimeSeries, prop *model.ObsProp)
- func GetBestSeries(in *pb.ObsTimeSeries, importName string, useLatest bool) (*pb.Series, *string)
- func GetStatAll(ctx context.Context, in *pb.GetStatAllRequest, store *store.Store) (*pb.GetStatAllResponse, error)
- func GetStatSeries(ctx context.Context, in *pb.GetStatSeriesRequest, store *store.Store) (*pb.GetStatSeriesResponse, error)
- func GetStatSet(ctx context.Context, in *pb.GetStatSetRequest, store *store.Store) (*pb.GetStatSetResponse, error)
- func GetStatSetSeries(ctx context.Context, in *pb.GetStatSetSeriesRequest, store *store.Store) (*pb.GetStatSetSeriesResponse, error)
- func GetStatSetSeriesWithinPlace(ctx context.Context, in *pb.GetStatSetSeriesWithinPlaceRequest, ...) (*pb.GetStatSetSeriesResponse, error)
- func GetStatSetWithinPlace(ctx context.Context, in *pb.GetStatSetWithinPlaceRequest, store *store.Store) (*pb.GetStatSetResponse, error)
- func GetStatSetWithinPlaceAll(ctx context.Context, in *pb.GetStatSetWithinPlaceRequest, store *store.Store) (*pb.GetStatSetAllResponse, error)
- func GetStatValue(ctx context.Context, in *pb.GetStatValueRequest, store *store.Store) (*pb.GetStatValueResponse, error)
- func GetStats(ctx context.Context, in *pb.GetStatsRequest, store *store.Store) (*pb.GetStatsResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FilterAndRank ¶
func FilterAndRank(in *model.ObsTimeSeries, prop *model.ObsProp)
FilterAndRank filters and ranks ObsTimeSeries in place.
func GetBestSeries ¶
func GetBestSeries( in *pb.ObsTimeSeries, importName string, useLatest bool, ) (*pb.Series, *string)
GetBestSeries gets the best series for a collection of series with different metadata.
- If "importName" is set, pick the series with the import name.
- If "useLatest" is true, pick the series with latest date and set the second return value to be the latest date.
Note "importName" is preferred over "useLatest".
func GetStatAll ¶
func GetStatAll(ctx context.Context, in *pb.GetStatAllRequest, store *store.Store) ( *pb.GetStatAllResponse, error)
GetStatAll implements API for Mixer.GetStatAll.
func GetStatSeries ¶
func GetStatSeries( ctx context.Context, in *pb.GetStatSeriesRequest, store *store.Store) ( *pb.GetStatSeriesResponse, error)
GetStatSeries implements API for Mixer.GetStatSeries. TODO(shifucun): consilidate and dedup the logic among these similar APIs.
func GetStatSet ¶
func GetStatSet(ctx context.Context, in *pb.GetStatSetRequest, store *store.Store) ( *pb.GetStatSetResponse, error)
GetStatSet implements API for Mixer.GetStatSet.
func GetStatSetSeries ¶
func GetStatSetSeries(ctx context.Context, in *pb.GetStatSetSeriesRequest, store *store.Store) ( *pb.GetStatSetSeriesResponse, error)
GetStatSetSeries implements API for Mixer.GetStatSetSeries.
func GetStatSetSeriesWithinPlace ¶
func GetStatSetSeriesWithinPlace( ctx context.Context, in *pb.GetStatSetSeriesWithinPlaceRequest, store *store.Store) ( *pb.GetStatSetSeriesResponse, error, )
GetStatSetSeriesWithinPlace implements API for Mixer.GetStatSetSeriesWithinPlace.
func GetStatSetWithinPlace ¶
func GetStatSetWithinPlace( ctx context.Context, in *pb.GetStatSetWithinPlaceRequest, store *store.Store) ( *pb.GetStatSetResponse, error, )
GetStatSetWithinPlace implements API for Mixer.GetStatSetWithinPlace.
func GetStatSetWithinPlaceAll ¶
func GetStatSetWithinPlaceAll( ctx context.Context, in *pb.GetStatSetWithinPlaceRequest, store *store.Store) ( *pb.GetStatSetAllResponse, error, )
GetStatSetWithinPlaceAll implements API for Mixer.GetStatSetWithinPlaceAll.
func GetStatValue ¶
func GetStatValue(ctx context.Context, in *pb.GetStatValueRequest, store *store.Store) ( *pb.GetStatValueResponse, error)
GetStatValue implements API for Mixer.GetStatValue.
Types ¶
This section is empty.