Mocked Data Source

class endless.framework.source_mock.MockSource(tag, timestamps, data)[source]

Emits configurably shaped samples with configurable timestamps.

__init__(tag, timestamps, data)[source]
Parameters:
  • tag – emitted samples carry this tag

  • timestamps – async-iterable sequence of dattime.datetime instances

  • data – if callable: called with current timestamp to produce data; if not, taken literally as data