stat

Documentation

Index

• func CollectDistinctSourceSeries(seriesList ...[]*pb.SourceSeries) []*pb.SourceSeries
• func FilterAndRank(in *model.ObsTimeSeries, prop *model.StatObsProp)
• func FilterSeries(in []*model.SourceSeries, prop *model.StatObsProp) []*model.SourceSeries
• 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 GetStatDateWithinPlace(ctx context.Context, in *pb.GetStatDateWithinPlaceRequest, store *store.Store) (*pb.GetStatDateWithinPlaceResponse, 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 GetStats(ctx context.Context, in *pb.GetStatsRequest, store *store.Store) (*pb.GetStatsResponse, error)
• func GetValueFromBestSource(in *model.ObsTimeSeries, date string) (float64, error)
• func GetValueFromBestSourcePb(in *pb.ObsTimeSeries, date string) (*pb.PointStat, *pb.StatMetadata)
• func ReadStatCollection(ctx context.Context, btGroup *bigtable.Group, rowList cbt.RowList, ...) (map[string]*pb.ObsCollection, error)
• func ReadStats(ctx context.Context, btGroup *bigtable.Group, rowList cbt.RowList, ...) (map[string]map[string]*model.ObsTimeSeries, error)
• func ReadStatsPb(ctx context.Context, btGroup *bigtable.Group, rowList cbt.RowList, ...) (map[string]map[string]*pb.ObsTimeSeries, error)
• func TokenFn(keyTokens map[string]*util.PlaceStatVar) func(rowKey string) (string, error)

Functions

func CollectDistinctSourceSeries

func CollectDistinctSourceSeries(seriesList ...[]*pb.SourceSeries) []*pb.SourceSeries

CollectDistinctSourceSeries merges lists of SourceSeries. For same source series, the one with more data points is used. In most cases, this is the series with the latest data as well.

func FilterAndRank

func FilterAndRank(in *model.ObsTimeSeries, prop *model.StatObsProp)

FilterAndRank filters and ranks ObsTimeSeries in place.

func FilterSeries

func FilterSeries(in []*model.SourceSeries, prop *model.StatObsProp) []*model.SourceSeries

FilterSeries filters a list of source series given the observation properties.

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 GetStatDateWithinPlace

func GetStatDateWithinPlace(
	ctx context.Context, in *pb.GetStatDateWithinPlaceRequest, store *store.Store) (
	*pb.GetStatDateWithinPlaceResponse, error)

GetStatDateWithinPlace implements API for Mixer.GetStatDateWithinPlace.

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 GetStats

func GetStats(ctx context.Context, in *pb.GetStatsRequest, store *store.Store) (
	*pb.GetStatsResponse, error)

GetStats implements API for Mixer.GetStats.

func GetValueFromBestSource

func GetValueFromBestSource(in *model.ObsTimeSeries, date string) (float64, error)

GetValueFromBestSource get the stat value from top ranked source series.

When date is given, it get the value from the highest ranked source series that has the date.

When date is not given, it get the latest value from the highest ranked source series.

func GetValueFromBestSourcePb

func GetValueFromBestSourcePb(
	in *pb.ObsTimeSeries, date string) (*pb.PointStat, *pb.StatMetadata)

GetValueFromBestSourcePb get the stat value from ObsTimeSeries (protobuf version)

When date is given, it get the value from the highest ranked source series that has the date.

When date is not given, it get the latest value from all the source series. If two sources has the same latest date, the highest ranked source is preferred.

func ReadStatCollection

func ReadStatCollection(
	ctx context.Context,
	btGroup *bigtable.Group,
	rowList cbt.RowList,
	keyTokens map[string]string) (
	map[string]*pb.ObsCollection, error)

ReadStatCollection reads and process ObsCollection cache from BigTable in parallel.

func ReadStats

func ReadStats(
	ctx context.Context,
	btGroup *bigtable.Group,
	rowList cbt.RowList,
	keyTokens map[string]*util.PlaceStatVar) (
	map[string]map[string]*model.ObsTimeSeries, error)

ReadStats reads and process BigTable rows in parallel. Consider consolidate this function and bigTableReadRowsParallel.

func ReadStatsPb

func ReadStatsPb(
	ctx context.Context,
	btGroup *bigtable.Group,
	rowList cbt.RowList,
	keyTokens map[string]*util.PlaceStatVar) (
	map[string]map[string]*pb.ObsTimeSeries, error)

ReadStatsPb reads and process BigTable rows in parallel. Consider consolidate this function and bigTableReadRowsParallel.

func TokenFn

func TokenFn(
	keyTokens map[string]*util.PlaceStatVar) func(rowKey string) (string, error)

TokenFn generates a function that convert row key to token string.