Versions in this module Expand all Collapse all v0 v0.1.0 Apr 3, 2023 Changes in this version + var ErrInvalidConfigFrameSize = errors.New(...) + var ErrInvalidConfigSelector = errors.New(...) + type Cache struct + func NewCache(selector *Selector, seed int64) *Cache + func (c *Cache) GetSelector() *Selector + func (c *Cache) Post(row Row) + func (c *Cache) PullRandom() Tuple + type CacheList struct + func NewCacheList() *CacheList + func (cl *CacheList) Add(cache *Cache) + func (cl *CacheList) All() []*Cache + func (cl *CacheList) Post(row Row) + type Configuration struct + FrameSize int + Seed int64 + Selectors []any + Version string + func LoadConfigurationFromYAML(filename string) (Configuration, error) + func (c Configuration) BuildDriver() *Driver + func (c Configuration) MustValidate() + type Driver struct + func NewDriver(seed int64, frameSize int) *Driver + func (d *Driver) AddSelector(selector *Selector) + func (d *Driver) Run(reader RowReader, collector RowCollector) + type Frame struct + func NewFrame(size int) *Frame + func (f *Frame) FillUp(reader RowReader, callback func(Row)) bool + func (f *Frame) PullFirst() Row + type Provider = func() Tuple + type Row = *parser.Object + type RowCollector interface + Collect func(row Row) error + type RowReader interface + HasRow func() bool + ReadRow func() (Row, error) + type Selector struct + func NewSelector(jsonpaths ...string) *Selector + func (s *Selector) Select(row Row) []Tuple + func (s *Selector) Update(row Row, provider Provider) + type Tuple = *parser.Array + func NewTuple() Tuple