Type alias TimeSeriesStatsConfig<I, O>

Type declaration

• aggregate: ((args: TimeSeriesAggregatorFnArgs<I, O>) => O)

  • • (args: TimeSeriesAggregatorFnArgs<I, O>): O

    • The function to aggregate the input stream with.

      Parameters

      • args: TimeSeriesAggregatorFnArgs<I, O>

        The arguments to be passed to the aggregator.

      Returns O

• getInputStream: ((args: InputStreamFactoryFnArgs) => Promise<StorageValueStream<I>>)

  • • (args: InputStreamFactoryFnArgs): Promise<StorageValueStream<I>>

    • The function representing the event input stream for the given time frame.

      Returns

      The event stream.

      Parameters

      • args: InputStreamFactoryFnArgs

        The arguments to be passed to the input stream.

      Returns Promise<StorageValueStream<I>>

• Optional reverse?: boolean

  Whether to process the time series in reverse order (from first to last). If false, then the latest events will be processed first.

• startDate: number

  The start date in milliseconds at which to start aggregating the time series.

• timeFrames: TimeFrame[]

  The time frame sizes to aggregate.

• type: string

  The user defined type of the time series. Must be unique.