streamer

Documentation

Index

• Variables
• func Configure(pID int, rID string, rowsParam string, startTime int, endTime int, ...)
• func StreamData(pID int, rID string, fillDataRow func(string, map[string]interface{}))
• type QueryConfig

Variables

var Origin = ""

Functions

func Configure

func Configure(pID int, rID string, rowsParam string, startTime int, endTime int, dataPointCount int, w http.ResponseWriter)

func StreamData

func StreamData(pID int, rID string, fillDataRow func(string, map[string]interface{}))

StreamData starts data streaming using the respective ticker stored in configMap. This function shall be called from a REST request handler function Based on the parsed parameters of the request the configMap is extended. Structure of config map:

Panel -> queries/panel -> series/queries

At the moment each query has its own ticker channel setup based on the sampling time (calculated based on the grafana data points config) Each series is represented by a string that can be configured in grafana through the dataText field. Once the ticker is set, the respective query results will be streamed back (periodical http flush) to the grafana server.

Types

type QueryConfig

type QueryConfig struct {
	Writer http.ResponseWriter
	Series []string
	Ticker *time.Ticker
}