Versions in this module Expand all Collapse all v0 v0.2.6 Feb 13, 2024 v0.2.5 Feb 12, 2024 Changes in this version + const Kill + const Pause + const Reload + const Resume + const Start + const Stop + func ReadCSV(path string) ([][]string, error) + type DataSet interface + ColumnNames func() []interface{} + DataPoint func() (interface{}, bool) + Reload func() error + Reset func() + func NewDataSet(csvPath string, replay bool, dataAsMap, allAtOnce bool) (DataSet, error) + type Emitter struct + func NewEmitter(logger log.Logger, handler trigger.Handler) (*Emitter, error) + func (e *Emitter) Kill() + func (e *Emitter) Name() string + func (e *Emitter) Pause() + func (e *Emitter) Reload() + func (e *Emitter) Resume() + func (e *Emitter) Run() + func (e *Emitter) Start() + func (e *Emitter) Stop() + type Factory struct + func (*Factory) Metadata() *trigger.Metadata + func (*Factory) New(config *trigger.Config) (trigger.Trigger, error) + type HandlerSettings struct + AllDataAtOnce bool + DataAsMap bool + EmitDelay int + FilePath string + GetColumnNames bool + ReplayData bool + type Output struct + ColumnNames []interface{} + Data interface{} + func (o *Output) FromMap(values map[string]interface{}) error + func (o *Output) ToMap() map[string]interface{} + type Settings struct + Port string + type Trigger struct + func (t *Trigger) Initialize(ctx trigger.InitContext) error + func (t *Trigger) Start() error + func (t *Trigger) Stop() error
Go to main page