streamtrigger

Documentation

Index

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

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.

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 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

type StreamTriggerConfig

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