Class LiveSeries<S>

constructor

• new LiveSeries<S extends SeriesSchema>(
      options: LiveSeriesOptions<S>,
  ): LiveSeries<S>

  Type Parameters

  • S extends SeriesSchema

  Parameters

  • options: LiveSeriesOptions<S>

  Returns LiveSeries<S>

Readonly[EMITS_EVICT]

Readonlyname

Readonlyschema

graceWindowMs

• get graceWindowMs(): number

  Returns number

length

• get length(): number

  Returns number

aggregate

• aggregate<const M extends Readonly<AggregateMapEntries<S>>>(
      sequence: Sequence,
      mapping: M,
  ): LiveAggregation<
      S,
      readonly [
          ColumnDef<"interval", "interval">,
          AggregateColumns<ValueColumnsForSchema<S>, M>,
      ],
  >

  Type Parameters

  • const M extends Readonly<AggregateMapEntries<S>>

  Parameters

  • sequence: Sequence
  • mapping: M

  Returns LiveAggregation<
      S,
      readonly [
          ColumnDef<"interval", "interval">,
          AggregateColumns<ValueColumnsForSchema<S>, M>,
      ],
  >

at

• at(index: number): EventForSchema<S> | undefined

  Parameters

  • index: number

  Returns EventForSchema<S> | undefined

clear

• clear(): void

  Returns void

cumulative

• cumulative<const Targets extends string>(
      spec: {
          [K in string]:
              | "sum"
              | "count"
              | "min"
              | "max"
              | ((acc: number, value: number) => number)
      },
  ): LiveView<
      readonly [
          S[0],
          ReplaceSmoothedColumn<ValueColumnsForSchema<S>, Targets>,
      ],
  >

  Type Parameters

  • const Targets extends string

  Parameters

  • spec: {
        [K in string]:
            | "sum"
            | "count"
            | "min"
            | "max"
            | ((acc: number, value: number) => number)
    }

  Returns LiveView<
      readonly [
          S[0],
          ReplaceSmoothedColumn<ValueColumnsForSchema<S>, Targets>,
      ],
  >

diff

• diff<const Target extends string>(
      columns: Target | readonly Target[],
      options?: { drop?: boolean },
  ): LiveView<
      readonly [S[0], ReplaceSmoothedColumn<ValueColumnsForSchema<S>, Target>],
  >

  Type Parameters

  • const Target extends string

  Parameters

  • columns: Target | readonly Target[]
  • Optionaloptions: { drop?: boolean }

  Returns LiveView<
      readonly [S[0], ReplaceSmoothedColumn<ValueColumnsForSchema<S>, Target>],
  >

fill

• fill(
      strategy: LiveFillStrategy | LiveFillMapping<S>,
      options?: { limit?: number },
  ): LiveView<S>

  Parameters

  • strategy: LiveFillStrategy | LiveFillMapping<S>
  • Optionaloptions: { limit?: number }

  Returns LiveView<S>

filter

• filter(predicate: (event: EventForSchema<S>) => boolean): LiveView<S>

  Parameters

  • predicate: (event: EventForSchema<S>) => boolean

  Returns LiveView<S>

first

• first(): EventForSchema<S> | undefined

  Returns EventForSchema<S> | undefined

last

• last(): EventForSchema<S> | undefined

  Returns EventForSchema<S> | undefined

map

• map(fn: (event: EventForSchema<S>) => EventForSchema<S>): LiveView<S>

  Parameters

  • fn: (event: EventForSchema<S>) => EventForSchema<S>

  Returns LiveView<S>

on

• on(type: "event", fn: EventListener<S>): () => void

  Parameters

  • type: "event"
  • fn: EventListener<S>

  Returns () => void

• on(type: "batch", fn: BatchListener<S>): () => void

  Parameters

  • type: "batch"
  • fn: BatchListener<S>

  Returns () => void

• on(type: "evict", fn: EvictListener<S>): () => void

  Parameters

  • type: "evict"
  • fn: EvictListener<S>

  Returns () => void

partitionBy

• partitionBy<K extends string = string>(
      by: keyof EventDataForSchema<S> & string,
      options?: LivePartitionedOptions<K>,
  ): LivePartitionedSeries<S, K>

  Live counterpart to TimeSeries.partitionBy. Routes events into per-partition LiveSeries sub-buffers, each with its own retention, grace window, and stateful operator pipeline. Use apply((sub) => sub.fill(...).rolling(...)) to compose live operators per partition; collect() to fan partitioned outputs into a unified LiveSeries.

  Multi-entity series: every stateful live operator (rolling, fill, diff, rate, cumulative, pctChange) silently mixes data across entities on a multi-host stream unless scoped per-partition first.

  Post-commit error semantics. The partition view runs as a 'event' listener on this LiveSeries. By the time a partitioning failure throws (a rogue value not in declared groups, or a stricter partition ordering rejecting an event the source accepted), the source has already committed the event — this.length reflects it. The caller's push() surfaces the listener's throw, but the source state has already moved. Validate inputs upstream of push() if source/partition atomicity matters.

  See LivePartitionedSeries.

  Type Parameters

  • K extends string = string

  Parameters

  • by: keyof EventDataForSchema<S> & string
  • Optionaloptions: LivePartitionedOptions<K>

  Returns LivePartitionedSeries<S, K>

pctChange

• pctChange<const Target extends string>(
      columns: Target | readonly Target[],
      options?: { drop?: boolean },
  ): LiveView<
      readonly [S[0], ReplaceSmoothedColumn<ValueColumnsForSchema<S>, Target>],
  >

  Type Parameters

  • const Target extends string

  Parameters

  • columns: Target | readonly Target[]
  • Optionaloptions: { drop?: boolean }

  Returns LiveView<
      readonly [S[0], ReplaceSmoothedColumn<ValueColumnsForSchema<S>, Target>],
  >

push

• push(...rows: RowForSchema<S>[]): void

  Parameters

  • ...rows: RowForSchema<S>[]

  Returns void

rate

• rate<const Target extends string>(
      columns: Target | readonly Target[],
      options?: { drop?: boolean },
  ): LiveView<
      readonly [S[0], ReplaceSmoothedColumn<ValueColumnsForSchema<S>, Target>],
  >

  Type Parameters

  • const Target extends string

  Parameters

  • columns: Target | readonly Target[]
  • Optionaloptions: { drop?: boolean }

  Returns LiveView<
      readonly [S[0], ReplaceSmoothedColumn<ValueColumnsForSchema<S>, Target>],
  >

rolling

• rolling<const M extends Readonly<AggregateMapEntries<S>>>(
      window: RollingWindow,
      mapping: M,
  ): LiveRollingAggregation<
      S,
      readonly [S[0], AggregateColumns<ValueColumnsForSchema<S>, M>],
  >

  Type Parameters

  • const M extends Readonly<AggregateMapEntries<S>>

  Parameters

  • window: RollingWindow
  • mapping: M

  Returns LiveRollingAggregation<
      S,
      readonly [S[0], AggregateColumns<ValueColumnsForSchema<S>, M>],
  >

select

• select<const Keys extends readonly (keyof EventDataForSchema<S>)[]>(
      ...keys: Keys,
  ): LiveView<
      readonly [
          S[0],
          PickSelectedColumns<ValueColumnsForSchema<S>, Keys[number]>,
      ],
  >

  Type Parameters

  • const Keys extends readonly (keyof EventDataForSchema<S>)[]

  Parameters

  • ...keys: Keys

  Returns LiveView<
      readonly [
          S[0],
          PickSelectedColumns<ValueColumnsForSchema<S>, Keys[number]>,
      ],
  >

toTimeSeries

• toTimeSeries(name?: string): TimeSeries<S>

  Parameters

  • Optionalname: string

  Returns TimeSeries<S>

window

• window(size: RollingWindow): LiveView<S>

  Parameters

  • size: RollingWindow

  Returns LiveView<S>