streamtrigger

Documentation

Index

• func ColumnSeriesForPayload(cs *io.ColumnSeries) *map[string]interface{}
• func NewTrigger(conf map[string]interface{}) (trigger.Trigger, error)
• type Config
• type StreamTrigger
  • func (s *StreamTrigger) Fire(keyPath string, records []trigger.Record)

Functions

func ColumnSeriesForPayload

func ColumnSeriesForPayload(cs *io.ColumnSeries) *map[string]interface{}

ColumnSeriesForPayload extracts the single row from the column series that is queried by the trigger, to prepare it for a streaming payload. nolint:gocritic // TODO: refactor (change *map -> map and related code using lots of reflection0

func NewTrigger

func NewTrigger(conf map[string]interface{}) (trigger.Trigger, error)

NewTrigger returns a new on-disk aggregate trigger based on the configuration.

Types

type Config

type Config struct {
	Filter string `json:"filter"`
}

type StreamTrigger

type StreamTrigger struct {
	// contains filtered or unexported fields
}

func (*StreamTrigger) Fire

func (s *StreamTrigger) Fire(keyPath string, records []trigger.Record)

Fire is the hook to retrieve the latest written data and stream it over the websocket.