streamtrigger

package
v2.3.8+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 2, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL