memory

Documentation

Index

• type Datasource
  • func (d *Datasource) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type Entry

Types

type Datasource

type Datasource struct {
	Entries []Entry
}

func (*Datasource) Run

func (d *Datasource) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type Entry

type Entry struct {
	Record         Record
	WatermarkEntry bool
	Watermark      time.Time
}