Documentation ¶
Overview ¶
Package data provides data structures that Grafana recognizes.
The Frame object represents a Grafana Dataframe which can represent data such as tables and time series.
Frames can be encoded using Apache Arrow (https://arrow.apache.org/) for transmission.
The corresponding Grafana frontend package the @grafana/data package (https://github.com/grafana/grafana/tree/master/packages/grafana-data).
Index ¶
- Constants
- func ArrowBufferToJSON(b []byte, includeSchema bool, includeData bool) ([]byte, error)
- func ArrowToJSON(record array.Record, includeSchema bool, includeData bool) ([]byte, error)
- func FrameTestCompareOptions() []cmp.Option
- func FrameToJSON(frame *Frame, includeSchema bool, includeData bool) ([]byte, error)
- func GetMissing(fillMissing *FillMissing, field *Field, previousRowIdx int) (interface{}, error)
- func SortWideFrameFields(frame *Frame, keys ...string) error
- func ValidFieldType(t interface{}) bool
- type ConfFloat64
- type Converter
- type DataLink
- type Field
- func (f *Field) Append(e interface{})
- func (f *Field) At(idx int) interface{}
- func (f *Field) ConcreteAt(idx int) (val interface{}, ok bool)
- func (f *Field) CopyAt(idx int) interface{}
- func (f *Field) Delete(idx int)
- func (f *Field) Extend(i int)
- func (f *Field) FloatAt(idx int) (float64, error)
- func (f *Field) Insert(idx int, val interface{})
- func (f *Field) Len() int
- func (f *Field) Nullable() bool
- func (f *Field) PointerAt(idx int) interface{}
- func (f *Field) Set(idx int, val interface{})
- func (f *Field) SetConcrete(idx int, val interface{})
- func (f *Field) SetConfig(conf *FieldConfig) *Field
- func (f *Field) Type() FieldType
- type FieldConfig
- type FieldConverter
- type FieldType
- func (p FieldType) ItemTypeString() string
- func (p FieldType) MarshalJSON() ([]byte, error)
- func (p FieldType) NonNullableType() FieldType
- func (p FieldType) Nullable() bool
- func (p FieldType) NullableType() FieldType
- func (p FieldType) Numeric() bool
- func (p FieldType) String() string
- func (p FieldType) Time() bool
- func (p *FieldType) UnmarshalJSON(b []byte) error
- type Fields
- type FillMissing
- type FillMode
- type Frame
- func LongToWide(longFrame *Frame, fillMissing *FillMissing) (*Frame, error)
- func NewFrame(name string, fields ...*Field) *Frame
- func NewFrameOfFieldTypes(name string, fieldLen int, fTypes ...FieldType) *Frame
- func UnmarshalArrowFrame(b []byte) (*Frame, error)
- func WideToLong(wideFrame *Frame) (*Frame, error)
- func (f *Frame) AppendNotices(notices ...Notice)
- func (f *Frame) AppendRow(vals ...interface{})
- func (f *Frame) At(fieldIdx int, rowIdx int) interface{}
- func (f *Frame) ConcreteAt(fieldIdx int, rowIdx int) (val interface{}, ok bool)
- func (f *Frame) CopyAt(fieldIdx int, rowIdx int) interface{}
- func (f *Frame) DeleteRow(rowIdx int)
- func (f *Frame) EmptyCopy() *Frame
- func (f *Frame) Extend(i int)
- func (f *Frame) FilterRowsByField(fieldIdx int, filter func(i interface{}) (bool, error)) (*Frame, error)
- func (f *Frame) FloatAt(fieldIdx int, rowIdx int) (float64, error)
- func (f *Frame) InsertRow(rowIdx int, vals ...interface{})
- func (f *Frame) MarshalArrow() ([]byte, error)
- func (f *Frame) MarshalJSON() ([]byte, error)
- func (f *Frame) RowCopy(rowIdx int) []interface{}
- func (f *Frame) RowLen() (int, error)
- func (f *Frame) Rows() int
- func (f *Frame) Set(fieldIdx int, rowIdx int, val interface{})
- func (f *Frame) SetConcrete(fieldIdx int, rowIdx int, val interface{})
- func (f *Frame) SetFieldNames(names ...string) error
- func (f *Frame) SetMeta(m *FrameMeta) *Frame
- func (f *Frame) SetRow(rowIdx int, vals ...interface{})
- func (f *Frame) StringTable(maxFields, maxRows int) (string, error)
- func (f *Frame) TimeSeriesSchema() (tsSchema TimeSeriesSchema)
- func (f *Frame) TypeIndices(fTypes ...FieldType) []int
- func (f *Frame) UnmarshalJSON(b []byte) error
- type FrameInputConverter
- type FrameMeta
- type Framer
- type Frames
- type InspectType
- type Labels
- type Notice
- type NoticeSeverity
- type QueryStat
- type RangeValueMapper
- type SpecialValueMapper
- type SpecialValueMatch
- type Threshold
- type ThresholdsConfig
- type ThresholdsMode
- type TimeSeriesSchema
- type TimeSeriesType
- type ValueMapper
- type ValueMapping
- type ValueMappingResult
- type ValueMappings
- type VisType
Examples ¶
Constants ¶
const ( // VisTypeGraph indicates the response should be visualized using a graph. VisTypeGraph VisType = "graph" // VisTypeTable indicates the response should be visualized using a table. VisTypeTable = "table" // VisTypeLogs indicates the response should be visualized using a logs visualization. VisTypeLogs = "logs" // VisTypeTrace indicates the response should be visualized using a trace view visualization. VisTypeTrace = "trace" // VisTypeNodeGraph indicates the response should be visualized using a node graph visualization. VisTypeNodeGraph = "nodeGraph" )
Should be kept in sync with grafana/packages/grafana-data/src/types/data.ts#PreferredVisualisationType
const ExplicitNullValue = "null"
ExplicitNullValue is the string representation for null
const TimeSeriesTimeFieldName = "Time"
TimeSeriesTimeFieldName is the standard name for time series time fields
const TimeSeriesValueFieldName = "Value"
TimeSeriesValueFieldName is the standard name for time series value fields
Variables ¶
This section is empty.
Functions ¶
func ArrowBufferToJSON ¶ added in v0.89.0
ArrowBufferToJSON writes a frame to JSON NOTE: the format should be considered experimental until grafana 8 is released.
func ArrowToJSON ¶ added in v0.89.0
ArrowToJSON writes a frame to JSON NOTE: the format should be considered experimental until grafana 8 is released.
func FrameTestCompareOptions ¶
FrameTestCompareOptions returns go-cmp testing options to allow testing of Frame equivalence. Since the data within a Frame's Fields is not exported, this function allows the unexported values to be tested. The intent is to only use this for testing. nolint:gocyclo
func FrameToJSON ¶ added in v0.89.0
FrameToJSON writes a frame to JSON. NOTE: the format should be considered experimental until grafana 8 is released.
func GetMissing ¶ added in v0.58.0
func GetMissing(fillMissing *FillMissing, field *Field, previousRowIdx int) (interface{}, error)
GetMissing returns the value to be filled for a missing row field.
func SortWideFrameFields ¶ added in v0.72.0
SortWideFrameFields sorts the order of a wide time series Frame's Fields. If the frame is not a WideFrame, then an error is returned.
The Time that is the time index (the first time field of the original frame) is sorted first. Then Fields are sorted by their name followed by the order of the label keys provided. If no keys are provided, they are sorted by the string representation of their labels.
func ValidFieldType ¶
func ValidFieldType(t interface{}) bool
ValidFieldType returns if a primitive slice is a valid supported Field type.
Types ¶
type ConfFloat64 ¶
type ConfFloat64 float64
ConfFloat64 is a float64. It Marshals float64 values of NaN of Inf to null.
func (*ConfFloat64) MarshalJSON ¶
func (sf *ConfFloat64) MarshalJSON() ([]byte, error)
MarshalJSON fullfills the json.Marshaler interface.
func (*ConfFloat64) UnmarshalJSON ¶
func (sf *ConfFloat64) UnmarshalJSON(data []byte) error
UnmarshalJSON fullfills the json.Unmarshaler interface.
type Converter ¶ added in v0.36.0
type Converter func(v interface{}) (interface{}, error)
Converter is a function type for converting values in a Frame. It is the consumers responsibility to the check the underlying interface types of the input and return types to avoid panics.
type DataLink ¶
type DataLink struct { Title string `json:"title,omitempty"` TargetBlank bool `json:"targetBlank,omitempty"` URL string `json:"url,omitempty"` }
DataLink define what
type Field ¶
type Field struct { // Name is default identifier of the field. The name does not have to be unique, but the combination // of name and Labels should be unique for proper behavior in all situations. Name string `json:"name,omitempty"` // Labels is an optional set of key=value pairs that in addition to the name, should uniquely // identify a Field within a Frame. Labels Labels `json:"labels,omitempty"` // Config is optional display configuration information for Grafana Config *FieldConfig `json:"config,omitempty"` // contains filtered or unexported fields }
Field represents a typed column of data within a Frame.
A Field is essentially a slice of various types with extra properties and methods. See NewField() for supported types.
The slice data in the Field is a not exported, so methods on the Field are used to to manipulate its data.
func NewField ¶
NewField returns a instance of *Field. Supported types for values are:
Integers:
[]int8, []*int8, []int16, []*int16, []int32, []*int32, []int64, []*int64
Unsigned Integers:
[]uint8, []*uint8, []uint16, []*uint16, []uint32, []*uint32, []uint64, []*uint64
Floats:
[]float32, []*float32, []float64, []*float64
String, Bool, and Time:
[]string, []*string, []bool, []*bool, []time.Time, and []*time.Time.
If an unsupported values type is passed, NewField will panic. nolint:gocyclo
func NewFieldFromFieldType ¶
NewFieldFromFieldType creates a new Field of the given FieldType of length n.
func (*Field) Append ¶
func (f *Field) Append(e interface{})
Append appends element e to the Field. it will panic if the underlying type of e does not match the element type of the Field.
func (*Field) At ¶
At returns the the element at index idx of the Field. It will panic if idx is out of range.
func (*Field) ConcreteAt ¶
ConcreteAt returns the concrete value at the specified index idx. A non-pointer type is returned regardless if the underlying vector is a pointer type or not. If the value is a pointer type, and is nil, then the zero value is returned and ok will be false.
func (*Field) CopyAt ¶
CopyAt returns a copy of the value of the specified index idx. It will panic if idx is out of range.
func (*Field) Extend ¶
Extend extends the Field length by i. Consider using Frame.Extend() when possible since all Fields within a Frame need to be of the same length before marshalling and transmission.
func (*Field) FloatAt ¶ added in v0.31.0
FloatAt returns a float64 at the specified index idx for all supported Field types. It will panic if idx is out of range.
If the Field type is numeric and the value at idx is nil, NaN is returned. Precision may be lost on large numbers.
If the Field type is a bool then 0 is return if false or nil, and 1 if true.
If the Field type is time.Time, then the millisecond epoch representation of the time is returned, or NaN is the value is nil.
If the Field type is a string, then strconv.ParseFloat is called on it and will return an error if ParseFloat errors. If the value is nil, NaN is returned. nolint:gocyclo
func (*Field) Insert ¶ added in v0.58.0
Insert extends the Field length by 1, shifts any existing field values at indices equal or greater to idx by one place and inserts val at index idx of the Field. If idx is equal to the Field length, then val will be appended. It idx exceeds the Field length, this method will panic.
func (*Field) PointerAt ¶
PointerAt returns a pointer to the value at idx of the Field. It will panic if idx is out of range.
func (*Field) Set ¶
Set sets the Field's value at index idx to val. It will panic if idx is out of range or if the underlying type of val does not match the element type of the Field.
func (*Field) SetConcrete ¶ added in v0.58.0
SetConcrete sets the Field's value at index idx to val. val must be a non-pointer type or a panic will occur. If the underlying FieldType is nullable it will set val as a pointer to val. If the FieldType is not nullable, then this method behaves the same as the Set method. It will panic if the underlying type of val does not match the element concrete type of the Field.
func (*Field) SetConfig ¶
func (f *Field) SetConfig(conf *FieldConfig) *Field
SetConfig modifies the Field's Config property to be set to conf and returns the Field.
type FieldConfig ¶
type FieldConfig struct { // DisplayName overrides Grafana default naming, should not be used from a data source DisplayName string `json:"displayName,omitempty"` // DisplayNameFromDS overrides Grafana default naming in a better way that allows users to override it easily. DisplayNameFromDS string `json:"displayNameFromDS,omitempty"` // Path is an explicit path to the field in the datasource. When the frame meta includes a path, // this will default to `${frame.meta.path}/${field.name} // // When defined, this value can be used as an identifier within the datasource scope, and // may be used as an identifier to update values in a subsequent request Path string `json:"path,omitempty"` // Description is human readable field metadata Description string `json:"description,omitempty"` // Filterable indicates if the Field's data can be filtered by additional calls. Filterable *bool `json:"filterable,omitempty"` // Writeable indicates that the datasource knows how to update this value Writeable *bool `json:"writeable,omitempty"` // Numeric Options Unit string `json:"unit,omitempty"` // is the string to display to represent the Field's unit, such as "Requests/sec" Decimals *uint16 `json:"decimals,omitempty"` // is the number of decimal places to display Min *ConfFloat64 `json:"min,omitempty"` // is the maximum value of fields in the column. When present the frontend can skip the calculation. Max *ConfFloat64 `json:"max,omitempty"` // see Min // Convert input values into a display string Mappings ValueMappings `json:"mappings,omitempty"` // Map numeric values to states Thresholds *ThresholdsConfig `json:"thresholds,omitempty"` // Map values to a display color // NOTE: this interface is under development in the frontend... so simple map for now Color map[string]interface{} `json:"color,omitempty"` // The behavior when clicking on a result Links []DataLink `json:"links,omitempty"` // Alternative to empty string NoValue string `json:"noValue,omitempty"` // Panel Specific Values Custom map[string]interface{} `json:"custom,omitempty"` }
FieldConfig represents the display properties for a Field.
func (*FieldConfig) SetDecimals ¶
func (fc *FieldConfig) SetDecimals(v uint16) *FieldConfig
SetDecimals modifies the FieldConfig's Decimals property to be set to v and returns the FieldConfig. It is a convenience function since the Decimals property is a pointer.
func (*FieldConfig) SetFilterable ¶
func (fc *FieldConfig) SetFilterable(b bool) *FieldConfig
SetFilterable modifies the FieldConfig's Filterable property to be set to b and returns the FieldConfig. It is a convenience function since the Filterable property is a pointer.
func (*FieldConfig) SetMax ¶
func (fc *FieldConfig) SetMax(v float64) *FieldConfig
SetMax modifies the FieldConfig's Max property to be set to v and returns the FieldConfig. It is a convenience function since the Min property is a pointer.
func (*FieldConfig) SetMin ¶
func (fc *FieldConfig) SetMin(v float64) *FieldConfig
SetMin modifies the FieldConfig's Min property to be set to v and returns the FieldConfig. It is a convenience function since the Min property is a pointer.
type FieldConverter ¶ added in v0.36.0
type FieldConverter struct { // OutputFieldType is the type of Field that will be created. OutputFieldType FieldType // Converter is a conversion function that is called when setting Field values with a FrameInputConverter. // Care must be taken that the type returned by the conversion function matches the member type of the FieldType, // and that the input type matches the expected input type for the Converter function, or panics can occur. // If the Converter is nil, no conversion is performed when calling methods to set values. Converter Converter }
A FieldConverter is a type to support building Frame fields of a different type than one's input data.
type FieldType ¶
type FieldType int
FieldType indicates the Go type underlying the Field.
const ( // FieldTypeUnknown indicates that we do not know the field type FieldTypeUnknown FieldType = iota // FieldTypeInt8 indicates the underlying primitive is a []int8. FieldTypeInt8 // FieldTypeNullableInt8 indicates the underlying primitive is a []*int8. FieldTypeNullableInt8 // FieldTypeInt16 indicates the underlying primitive is a []int16. FieldTypeInt16 // FieldTypeNullableInt16 indicates the underlying primitive is a []*int16. FieldTypeNullableInt16 // FieldTypeInt32 indicates the underlying primitive is a []int32. FieldTypeInt32 // FieldTypeNullableInt32 indicates the underlying primitive is a []*int32. FieldTypeNullableInt32 // FieldTypeInt64 indicates the underlying primitive is a []int64. FieldTypeInt64 // FieldTypeNullableInt64 indicates the underlying primitive is a []*int64. FieldTypeNullableInt64 // FieldTypeUint8 indicates the underlying primitive is a []uint8. FieldTypeUint8 // FieldTypeNullableUint8 indicates the underlying primitive is a []*uint8. FieldTypeNullableUint8 // FieldTypeUint16 indicates the underlying primitive is a []uint16. FieldTypeUint16 // FieldTypeNullableUint16 indicates the underlying primitive is a []*uint16. FieldTypeNullableUint16 // FieldTypeUint32 indicates the underlying primitive is a []uint32. FieldTypeUint32 // FieldTypeNullableUint32 indicates the underlying primitive is a []*uint32. FieldTypeNullableUint32 // FieldTypeUint64 indicates the underlying primitive is a []uint64. FieldTypeUint64 // FieldTypeNullableUint64 indicates the underlying primitive is a []*uint64. FieldTypeNullableUint64 // FieldTypeFloat32 indicates the underlying primitive is a []float32. FieldTypeFloat32 // FieldTypeNullableFloat32 indicates the underlying primitive is a []*float32. FieldTypeNullableFloat32 // FieldTypeFloat64 indicates the underlying primitive is a []float64. FieldTypeFloat64 // FieldTypeNullableFloat64 indicates the underlying primitive is a []*float64. FieldTypeNullableFloat64 // FieldTypeString indicates the underlying primitive is a []string. FieldTypeString // FieldTypeNullableString indicates the underlying primitive is a []*string. FieldTypeNullableString // FieldTypeBool indicates the underlying primitive is a []bool. FieldTypeBool // FieldTypeNullableBool indicates the underlying primitive is a []*bool. FieldTypeNullableBool // FieldTypeTime indicates the underlying primitive is a []time.Time. FieldTypeTime // FieldTypeNullableTime indicates the underlying primitive is a []*time.Time. FieldTypeNullableTime )
func FieldTypeFor ¶ added in v0.90.0
func FieldTypeFor(t interface{}) FieldType
FieldTypeFor returns a concrete type for a given interface or unknown if not known
func FieldTypeFromItemTypeString ¶ added in v0.89.0
FieldTypeFromItemTypeString returns a field type from the current string
func NumericFieldTypes ¶
func NumericFieldTypes() []FieldType
NumericFieldTypes returns a slice of FieldTypes that are numeric.
func (FieldType) ItemTypeString ¶
ItemTypeString returns the string representation of the type of element within in the vector
func (FieldType) MarshalJSON ¶ added in v0.89.0
MarshalJSON marshals the enum as a quoted json string
func (FieldType) NonNullableType ¶ added in v0.90.0
NonNullableType converts the FieldType to the corresponding not-nullable type.
func (FieldType) NullableType ¶ added in v0.52.0
NullableType converts the FieldType to the corresponding nullable type.
func (FieldType) Time ¶ added in v0.72.0
Time returns if Field type is a time type (FieldTypeTime or FieldTypeNullableTime).
func (*FieldType) UnmarshalJSON ¶ added in v0.89.0
UnmarshalJSON unmarshals a quoted json string to the enum value
type FillMissing ¶ added in v0.52.0
FillMissing is a struct containing the fill mode and the fill value if fill mode is FillModeValue
type FillMode ¶ added in v0.52.0
type FillMode int
FillMode is an integer type denoting how missing values should be filled.
type Frame ¶
type Frame struct { // Name is used in some Grafana visualizations. Name string // Fields are the columns of a frame. // All Fields must be of the same the length when marshalling the Frame for transmission. Fields []*Field // RefID is a property that can be set to match a Frame to its orginating query. RefID string // Meta is metadata about the Frame, and includes space for custom metadata. Meta *FrameMeta }
Frame is a columnar data structure where each column is a Field.
Each Field is well typed by its FieldType and supports optional Labels.
A Frame is a general data container for Grafana. A Frame can be table data or time series data depending on its content and field types.
Example (TSDBTimeSeriesDifferentTimeIndices) ¶
package main import ( "fmt" "time" "github.com/grafana/grafana-plugin-sdk-go/data" ) type mockPoint struct { Time time.Time Value float64 } type mockSeries struct { Name string Labels map[string]string Points []mockPoint } type mockResponse struct { Series []mockSeries } func main() { // A common tsdb response pattern is to return a collection // of time series where each time series is uniquely identified // by a Name and a set of key value pairs (Labels (a.k.a Tags)). // In the case where the responses does not share identical time values and length (a single time index), // then the proper representation is Frames ([]*Frame). Where each Frame has a Time type field and one or more // Number fields. // Each Frame should have its value sorted by time in ascending order. res := mockResponse{ []mockSeries{ { Name: "cpu", Labels: map[string]string{"host": "a"}, Points: []mockPoint{ { time.Date(2020, 1, 2, 3, 4, 0, 0, time.UTC), 3, }, { time.Date(2020, 1, 2, 3, 5, 0, 0, time.UTC), 6, }, }, }, { Name: "cpu", Labels: map[string]string{"host": "b"}, Points: []mockPoint{ { time.Date(2020, 1, 2, 3, 4, 1, 0, time.UTC), 4, }, { time.Date(2020, 1, 2, 3, 5, 1, 0, time.UTC), 7, }, }, }, }, } frames := make([]*data.Frame, len(res.Series)) for i, series := range res.Series { frames[i] = data.NewFrame(series.Name, data.NewField("time", nil, make([]time.Time, len(series.Points))), data.NewField(series.Name, series.Labels, make([]float64, len(series.Points))), ) for pIdx, point := range series.Points { frames[i].Set(0, pIdx, point.Time) frames[i].Set(1, pIdx, point.Value) } } for _, frame := range frames { st, _ := frame.StringTable(-1, -1) fmt.Println(st) } }
Output: Name: cpu Dimensions: 2 Fields by 2 Rows +-------------------------------+-----------------+ | Name: time | Name: cpu | | Labels: | Labels: host=a | | Type: []time.Time | Type: []float64 | +-------------------------------+-----------------+ | 2020-01-02 03:04:00 +0000 UTC | 3 | | 2020-01-02 03:05:00 +0000 UTC | 6 | +-------------------------------+-----------------+ Name: cpu Dimensions: 2 Fields by 2 Rows +-------------------------------+-----------------+ | Name: time | Name: cpu | | Labels: | Labels: host=b | | Type: []time.Time | Type: []float64 | +-------------------------------+-----------------+ | 2020-01-02 03:04:01 +0000 UTC | 4 | | 2020-01-02 03:05:01 +0000 UTC | 7 | +-------------------------------+-----------------+
Example (TableLikeLongTimeSeries) ¶
package main import ( "fmt" "time" "github.com/grafana/grafana-plugin-sdk-go/data" ) func main() { // a common SQL or CSV like pattern is to have repeated times, multiple numbered value // columns, and string columns to identify a factors. This is a "Long" time series. // Presently the backend supports converting Long formatted series to "Wide" format // which the frontend understands. Goal is frontend support eventually // (https://github.com/grafana/grafana/issues/22219). type aTable struct { Headers []string Rows [][]interface{} } iSlice := func(is ...interface{}) []interface{} { s := make([]interface{}, len(is)) copy(s, is) return s } myLongTable := aTable{ Headers: []string{"time", "aMetric", "bMetric", "SomeFactor"}, } myLongTable.Rows = append(myLongTable.Rows, iSlice(time.Date(2020, 1, 2, 3, 4, 0, 0, time.UTC), 2.0, 10.0, "foo"), iSlice(time.Date(2020, 1, 2, 3, 4, 0, 0, time.UTC), 5.0, 15.0, "bar"), iSlice(time.Date(2020, 1, 2, 3, 5, 0, 0, time.UTC), 3.0, 11.0, "foo"), iSlice(time.Date(2020, 1, 2, 3, 5, 0, 0, time.UTC), 6.0, 16.0, "bar"), ) frame := data.NewFrameOfFieldTypes("Long", 0, data.FieldTypeTime, data.FieldTypeFloat64, data.FieldTypeFloat64, data.FieldTypeString, ) _ = frame.SetFieldNames(myLongTable.Headers...) for _, row := range myLongTable.Rows { frame.AppendRow(row...) } st, _ := frame.StringTable(-1, -1) fmt.Println(st) w, _ := data.LongToWide(frame, nil) w.Name = "Wide" st, _ = w.StringTable(-1, -1) fmt.Println(st) }
Output: Name: Long Dimensions: 4 Fields by 4 Rows +-------------------------------+-----------------+-----------------+------------------+ | Name: time | Name: aMetric | Name: bMetric | Name: SomeFactor | | Labels: | Labels: | Labels: | Labels: | | Type: []time.Time | Type: []float64 | Type: []float64 | Type: []string | +-------------------------------+-----------------+-----------------+------------------+ | 2020-01-02 03:04:00 +0000 UTC | 2 | 10 | foo | | 2020-01-02 03:04:00 +0000 UTC | 5 | 15 | bar | | 2020-01-02 03:05:00 +0000 UTC | 3 | 11 | foo | | 2020-01-02 03:05:00 +0000 UTC | 6 | 16 | bar | +-------------------------------+-----------------+-----------------+------------------+ Name: Wide Dimensions: 5 Fields by 2 Rows +-------------------------------+------------------------+------------------------+------------------------+------------------------+ | Name: time | Name: aMetric | Name: aMetric | Name: bMetric | Name: bMetric | | Labels: | Labels: SomeFactor=bar | Labels: SomeFactor=foo | Labels: SomeFactor=bar | Labels: SomeFactor=foo | | Type: []time.Time | Type: []float64 | Type: []float64 | Type: []float64 | Type: []float64 | +-------------------------------+------------------------+------------------------+------------------------+------------------------+ | 2020-01-02 03:04:00 +0000 UTC | 5 | 2 | 15 | 10 | | 2020-01-02 03:05:00 +0000 UTC | 6 | 3 | 16 | 11 | +-------------------------------+------------------------+------------------------+------------------------+------------------------+
func LongToWide ¶
func LongToWide(longFrame *Frame, fillMissing *FillMissing) (*Frame, error)
LongToWide converts a Long formatted time series Frame to a Wide format (see TimeSeriesType for descriptions). The first Field of type time.Time or *time.Time will be the time index for the series, and will be the first field of the outputted longFrame.
During conversion: String and bool Fields in the longFrame become Labels on the Fields of wideFrame. The name of each string or bool Field becomes a label key, and the values of that Field become label values. Each unique combination of value Fields and set of Label key/values become a Field of longFrame.
Additionally, if the time index is a *time.Time field, it will become time.Time Field. If a *string Field has nil values, they are equivalent to "" when converted into labels.
Finally, the Meta field of the result Wide Frame is pointing to the reference of the Meta field of the input Long Frame.
An error is returned if any of the following are true: The input frame is not a long formatted time series frame. The input frame's Fields are of length 0. The time index is not sorted ascending by time. The time index has null values.
With a conversion of Long to Wide, and then back to Long via WideToLong(), the outputted Long Frame may not match the original inputted Long frame.
func NewFrame ¶
NewFrame returns a new Frame.
Example ¶
package main import ( "fmt" "math" "time" "github.com/grafana/grafana-plugin-sdk-go/data" ) func main() { aTime := time.Date(2020, 1, 2, 3, 4, 5, 0, time.UTC) var anInt64 int64 = 12 frame := data.NewFrame("Frame Name", data.NewField("Time", nil, []time.Time{aTime, aTime.Add(time.Minute)}), data.NewField("Temp", data.Labels{"place": "Ecuador"}, []float64{1, math.NaN()}), data.NewField("Count", data.Labels{"place": "Ecuador"}, []*int64{&anInt64, nil}), ) st, _ := frame.StringTable(-1, -1) fmt.Println(st) }
Output: Name: Frame Name Dimensions: 3 Fields by 2 Rows +-------------------------------+-----------------------+-----------------------+ | Name: Time | Name: Temp | Name: Count | | Labels: | Labels: place=Ecuador | Labels: place=Ecuador | | Type: []time.Time | Type: []float64 | Type: []*int64 | +-------------------------------+-----------------------+-----------------------+ | 2020-01-02 03:04:05 +0000 UTC | 1 | 12 | | 2020-01-02 03:05:05 +0000 UTC | NaN | null | +-------------------------------+-----------------------+-----------------------+
func NewFrameOfFieldTypes ¶ added in v0.36.0
NewFrameOfFieldTypes returns a Frame where the Fields are initialized to the corresponding field type in fTypes. Each Field will be of length FieldLen.
func UnmarshalArrowFrame ¶ added in v0.42.0
UnmarshalArrowFrame converts a byte representation of an arrow table to a Frame.
func WideToLong ¶
WideToLong converts a Wide formatted time series Frame to a Long formatted time series Frame (see TimeSeriesType for descriptions). The first Field of type time.Time or *time.Time in wideFrame will be the time index for the series, and will be the first field of the outputted wideFrame.
During conversion: All the unique keys in all of the Labels across the Fields of wideFrame become string Fields with the corresponding name in longFrame. The corresponding Labels values become values in those Fields of longFrame. For each unique non-timeIndex Field across the Fields of wideFrame (value fields), a Field of the same type is created in longFrame. For each unique set of Labels across the Fields of wideFrame, a row is added to longFrame, and then for each unique value Field, the corresponding value Field of longFrame is set.
Finally, the Meta field of the result Long Frame is pointing to the reference of the Meta field of the input Wide Frame.
An error is returned if any of the following are true: The input frame is not a wide formatted time series frame. The input row has no rows. The time index not sorted ascending by time. The time index has null values. Two numeric Fields have the same name but different types.
With a conversion of Wide to Long, and then back to Wide via LongToWide(), the outputted Wide Frame may not match the original inputted Wide frame.
func (*Frame) AppendNotices ¶ added in v0.44.0
AppendNotices adds notices to Frame f's metadata (Frame.Meta.Notices). If f has no metadata, this method will initialize it before adding notices.
func (*Frame) AppendRow ¶
func (f *Frame) AppendRow(vals ...interface{})
AppendRow adds a new row to the Frame by appending to each element of vals to the corresponding Field in the data. The Frame's Fields must be initialized or AppendRow will panic. The number of arguments must match the number of Fields in the Frame and each type must coorespond to the Field type or AppendRow will panic.
func (*Frame) At ¶
At returns the value of the specified fieldIdx and rowIdx. It will panic if either fieldIdx or rowIdx are out of range.
func (*Frame) ConcreteAt ¶
ConcreteAt returns the concrete value at the specified fieldIdx and rowIdx. A non-pointer type is returned regardless if the underlying type is a pointer type or not. If the value is a nil pointer, the the zero value is returned and ok will be false.
func (*Frame) CopyAt ¶
CopyAt returns a copy of the value of the specified fieldIdx and rowIdx. It will panic if either fieldIdx or rowIdx are out of range.
func (*Frame) DeleteRow ¶ added in v0.63.0
DeleteRow deletes row at index rowIdx of the Frame. DeleteRow calls each field's Delete If idx is out of range, this method will panic.
func (*Frame) EmptyCopy ¶ added in v0.28.0
EmptyCopy returns a copy of Frame f but with Fields of zero length, and no copy of the FieldConfigs, Metadata, or Warnings.
func (*Frame) FilterRowsByField ¶ added in v0.28.0
func (f *Frame) FilterRowsByField(fieldIdx int, filter func(i interface{}) (bool, error)) (*Frame, error)
FilterRowsByField returns a copy of frame f (as per EmptyCopy()) that includes rows where the filter returns true and no error. If filter returns an error, then an error is returned.
func (*Frame) FloatAt ¶ added in v0.31.0
FloatAt returns a float64 representation of the value at the specified fieldIdx and rowIdx, as per Field.FloatAt(). It will panic if either the fieldIdx or rowIdx are out of range.
func (*Frame) InsertRow ¶ added in v0.58.0
InsertRow adds a row at index rowIdx of the Frame. InsertRow calls each field's Insert which extends the Field length by 1, shifts any existing field values at indices equal or greater to rowIdx by one place and inserts the corresponding val at index rowIdx of the Field. If rowIdx is equal to the Frame RowLen, then val will be appended. If rowIdx exceeds the Field length, this method will panic.
func (*Frame) MarshalArrow ¶ added in v0.42.0
MarshalArrow converts the Frame to an arrow table and returns a byte representation of that table. All fields of a Frame must be of the same length or an error is returned.
func (*Frame) MarshalJSON ¶ added in v0.80.0
MarshalJSON marshals Frame to JSON.
func (*Frame) RowCopy ¶ added in v0.28.0
RowCopy returns an interface slice that contains the values of each Field for the given rowIdx.
func (*Frame) RowLen ¶
RowLen returns the the length of the Frame Fields. If the lengths of all the Fields are not the same an error is returned.
func (*Frame) Set ¶
Set sets the val at the specified fieldIdx and rowIdx. It will panic if either fieldIdx or rowIdx are out of range or if the underlying type of val does not match the element type of the Field.
func (*Frame) SetConcrete ¶ added in v0.58.0
SetConcrete sets the val at the specified fieldIdx and rowIdx. val must be a non-pointer type or a panic will occur. If the underlying FieldType is nullable it will set val as a pointer to val. If the FieldType is not nullable this method behaves the same as the Set method. It will panic if the underlying type of val does not match the element concrete type of the Field.
func (*Frame) SetFieldNames ¶ added in v0.36.0
SetFieldNames sets each Field Name in the frame to the corresponding frame. If the number of provided names does not match the number of Fields in the frame an error is returned.
func (*Frame) SetMeta ¶ added in v0.74.0
SetMeta sets the Frame's Meta attribute to m and returns the Frame.
func (*Frame) SetRow ¶ added in v0.58.0
SetRow sets vals at the index rowIdx of the Frame. SetRow calls each field's Set which sets the Field's value at index idx to val.
func (*Frame) StringTable ¶ added in v0.32.0
StringTable prints a human readable table of the Frame. The output should not be used for programmatic consumption or testing. The table's width is limited to maxFields and the length is limited to maxRows (a value of -1 is unlimited). If the width or length is exceeded, the last column or row displays "..." as the contents.
func (*Frame) TimeSeriesSchema ¶
func (f *Frame) TimeSeriesSchema() (tsSchema TimeSeriesSchema)
TimeSeriesSchema returns the TimeSeriesSchema of the frame. The TimeSeriesSchema's Type value will be TimeSeriesNot if it is not a time series.
func (*Frame) TypeIndices ¶
TypeIndices returns a slice of Field index positions for the given fTypes.
func (*Frame) UnmarshalJSON ¶ added in v0.80.0
UnmarshalJSON allows unmarshalling Frame from JSON.
type FrameInputConverter ¶ added in v0.36.0
type FrameInputConverter struct { Frame *Frame // contains filtered or unexported fields }
FrameInputConverter is a type to support building a Frame while also doing conversion as data is added to the Frame.
func NewFrameInputConverter ¶ added in v0.36.0
func NewFrameInputConverter(fieldConvs []FieldConverter, rowLen int) (*FrameInputConverter, error)
NewFrameInputConverter returns a FrameInputConverter which is used to create a Frame from data that needs value conversions. The FrameInputConverter will create a new Frame with fields based on the FieldConverters' OutputFieldTypes of length rowLen.
Example ¶
package main import ( "fmt" "log" "strconv" "time" "github.com/grafana/grafana-plugin-sdk-go/data" conv "github.com/grafana/grafana-plugin-sdk-go/data/converters" ) func main() { inputData := struct { // inputData is a pretend table-like structure response from an API. ColumnTypes []string ColumnNames []string Rows [][]string }{ []string{ "Stringz", "Floatz", "Timez", }, []string{ "Animal", "Weight (lbs)", "Time", }, [][]string{ {"sloth", "3.5", "1586014367"}, {"sloth", "5.5", "1586100767"}, {"sloth", "7", "1586187167"}, }, } // Build field converters appropriate for converting out pretend data structure. stringzFieldConverter := data.FieldConverter{ OutputFieldType: data.FieldTypeString, // No Converter, string = string } floatzFieldConverter := data.FieldConverter{ // a converter appropriate for our pretend API's Floatz type. OutputFieldType: data.FieldTypeFloat64, Converter: func(v interface{}) (interface{}, error) { val, ok := v.(string) if !ok { // or return some default value instead of erroring return nil, fmt.Errorf("expected string input but got type %T", v) } return strconv.ParseFloat(val, 64) }, } timezFieldConverter := data.FieldConverter{ // a converter appropriate for our pretend API's Timez type. OutputFieldType: data.FieldTypeTime, Converter: func(v interface{}) (interface{}, error) { val, ok := v.(string) if !ok { // or return some default value instead of erroring return nil, fmt.Errorf("expected string input but got type %T", v) } iV, err := strconv.ParseInt(val, 10, 64) if err != nil { return nil, fmt.Errorf("could not parse epoch time into an int64") } return time.Unix(iV, 0).UTC(), nil }, } // a map of pretend API's types to converters converterMap := map[string]data.FieldConverter{ "Stringz": stringzFieldConverter, "Floatz": floatzFieldConverter, "Timez": timezFieldConverter, } // build a slice of converters for Pretend API known types in the appropriate Field/Column order // for this specific response. converters := make([]data.FieldConverter, len(inputData.ColumnTypes)) for i, cType := range inputData.ColumnTypes { fc, ok := converterMap[cType] if !ok { fc = conv.AnyToString } converters[i] = fc } // Get a new FrameInputConverter, which includes a Frame with appropriate Field types and length // for out input data. convBuilder, err := data.NewFrameInputConverter(converters, len(inputData.Rows)) if err != nil { log.Fatal(err) } // Set field names err = convBuilder.Frame.SetFieldNames(inputData.ColumnNames...) if err != nil { log.Fatal(err) } // Insert data into the frame, passing data through the Converters before // writing to the frame. for rowIdx, row := range inputData.Rows { for fieldIdx, cell := range row { err = convBuilder.Set(fieldIdx, rowIdx, cell) if err != nil { log.Fatal(err) } } } convBuilder.Frame.Name = "Converted" st, _ := convBuilder.Frame.StringTable(-1, -1) fmt.Println(st) }
Output: Name: Converted Dimensions: 3 Fields by 3 Rows +----------------+--------------------+-------------------------------+ | Name: Animal | Name: Weight (lbs) | Name: Time | | Labels: | Labels: | Labels: | | Type: []string | Type: []float64 | Type: []time.Time | +----------------+--------------------+-------------------------------+ | sloth | 3.5 | 2020-04-04 15:32:47 +0000 UTC | | sloth | 5.5 | 2020-04-05 15:32:47 +0000 UTC | | sloth | 7 | 2020-04-06 15:32:47 +0000 UTC | +----------------+--------------------+-------------------------------+
func (*FrameInputConverter) Set ¶ added in v0.36.0
func (fic *FrameInputConverter) Set(fieldIdx, rowIdx int, val interface{}) error
Set sets val a FieldIdx and rowIdx of the frame. If the corresponding FieldConverter's Converter is not nil, then the Converter function is called before setting the value (otherwise Frame.Set is called directly). If an error is returned from the Converter function this function returns that error. Like Frame.Set and Field.Set, it will panic if fieldIdx or rowIdx are out of range.
type FrameMeta ¶ added in v0.35.0
type FrameMeta struct { // Path is a browsable path on the datasource. Path string `json:"path,omitempty"` // PathSeparator defines the separator pattern to decode a hiearchy. The default separator is '/'. PathSeparator string `json:"pathSeparator,omitempty"` // Custom datasource specific values. Custom interface{} `json:"custom,omitempty"` // Stats is an array of query result statistics. Stats []QueryStat `json:"stats,omitempty"` // Notices provide additional information about the data in the Frame that // Grafana can display to the user in the user interface. Notices []Notice `json:"notices,omitempty"` // Channel is the path to a stream in grafana live that has real-time updates for this data. Channel string `json:"channel,omitempty"` // PreferredVisualization is currently used to show results in Explore only in preferred visualisation option. PreferredVisualization VisType `json:"preferredVisualisationType,omitempty"` // ExecutedQueryString is the raw query sent to the underlying system. All macros and templating // have been applied. When metadata contains this value, it will be shown in the query inspector. ExecutedQueryString string `json:"executedQueryString,omitempty"` }
FrameMeta matches: https://github.com/grafana/grafana/blob/master/packages/grafana-data/src/types/data.ts#L11 NOTE -- in javascript this can accept any `[key: string]: any;` however this interface only exposes the values we want to be exposed
func FrameMetaFromJSON ¶ added in v0.35.0
FrameMetaFromJSON creates a QueryResultMeta from a json string
type Framer ¶ added in v0.80.0
Framer is simply an object that can be converted to Grafana data frames. This interface allows us to interact with types that represent data source objects without having to convert them to data frames first.
type Frames ¶ added in v0.42.0
type Frames []*Frame
Frames is a slice of Frame pointers. It is the main data container within a backend.DataResponse.
func UnmarshalArrowFrames ¶ added in v0.42.0
UnmarshalArrowFrames decodes a slice of Arrow encoded frames to Frames ([]*Frame) by calling the UnmarshalArrow function on each encoded frame. If an error occurs Frames will be nil. See Frames.UnMarshalArrow() for the inverse operation.
func (Frames) MarshalArrow ¶ added in v0.42.0
MarshalArrow encodes Frames into a slice of []byte using *Frame's MarshalArrow method on each Frame. If an error occurs [][]byte will be nil. See UnmarshalArrowFrames for the inverse operation.
type InspectType ¶ added in v0.44.0
type InspectType int
InspectType is a type for the Inspect property of a Notice.
const ( // InspectTypeNone is no suggestion for a tab of the panel editor in Grafana's user interface. InspectTypeNone InspectType = iota // InspectTypeMeta suggests the "meta" tab of the panel editor in Grafana's user interface. InspectTypeMeta // InspectTypeError suggests the "error" tab of the panel editor in Grafana's user interface. InspectTypeError // InspectTypeData suggests the "data" tab of the panel editor in Grafana's user interface. InspectTypeData // InspectTypeStats suggests the "stats" tab of the panel editor in Grafana's user interface. InspectTypeStats )
func (InspectType) String ¶ added in v0.44.0
func (n InspectType) String() string
type Labels ¶
Labels are used to add metadata to an object.
func LabelsFromString ¶
LabelsFromString parses the output of Labels.String() into a Labels object. It probably has some flaws.
func (Labels) Contains ¶
Contains returns true if all k=v pairs of the argument are in the receiver.
type Notice ¶ added in v0.44.0
type Notice struct { // Severity is the severity level of the notice: info, warning, or error. Severity NoticeSeverity `json:"severity,omitempty"` // Text is freeform descriptive text for the notice. Text string `json:"text"` // Link is an optional link for display in the user interface and can be an // absolute URL or a path relative to Grafana's root url. Link string `json:"link,omitempty"` // Inspect is an optional suggestion for which tab to display in the panel inspector // in Grafana's User interface. Can be meta, error, data, or stats. Inspect InspectType `json:"inspect,omitempty"` }
Notice provides a structure for presenting notifications in Grafana's user interface.
type NoticeSeverity ¶ added in v0.44.0
type NoticeSeverity int
NoticeSeverity is a type for the Severity property of a Notice.
const ( // NoticeSeverityInfo is informational severity. NoticeSeverityInfo NoticeSeverity = iota // NoticeSeverityWarning is warning severity. NoticeSeverityWarning // NoticeSeverityError is error severity. NoticeSeverityError )
func (NoticeSeverity) MarshalJSON ¶ added in v0.59.0
func (n NoticeSeverity) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaler interface.
func (NoticeSeverity) String ¶ added in v0.44.0
func (n NoticeSeverity) String() string
func (*NoticeSeverity) UnmarshalJSON ¶ added in v0.59.0
func (n *NoticeSeverity) UnmarshalJSON(b []byte) error
UnmarshalJSON implements the json.Unmarshaler interface.
type QueryStat ¶ added in v0.71.0
type QueryStat struct { FieldConfig Value float64 `json:"value"` }
QueryStat is used for storing arbitrary statistics metadata related to a query and its result, e.g. total request time, data processing time. The embedded FieldConfig's display name must be set. It corresponds to the QueryResultMetaStat on the frontend (https://github.com/grafana/grafana/blob/master/packages/grafana-data/src/types/data.ts#L53).
type RangeValueMapper ¶ added in v0.98.0
type RangeValueMapper struct { From *ConfFloat64 `json:"from,omitempty"` To *ConfFloat64 `json:"to,omitempty"` Result ValueMappingResult `json:"result"` }
type SpecialValueMapper ¶ added in v0.98.0
type SpecialValueMapper struct { Match SpecialValueMatch `json:"match"` Result ValueMappingResult `json:"result"` }
type SpecialValueMatch ¶ added in v0.98.0
type SpecialValueMatch string
const ( SpecialValueTrue SpecialValueMatch = "true" SpecialValueFalse SpecialValueMatch = "false" SpecialValueNull SpecialValueMatch = "null" SpecialValueNaN SpecialValueMatch = "nan" SpecialValueNullAndNaN SpecialValueMatch = "null+nan" SpecialValueEmpty SpecialValueMatch = "empty" )
type Threshold ¶
type Threshold struct { Value ConfFloat64 `json:"value,omitempty"` // First value is always -Infinity serialize to null Color string `json:"color,omitempty"` State string `json:"state,omitempty"` }
Threshold a single step on the threshold list
func NewThreshold ¶
NewThreshold Creates a new Threshold object
type ThresholdsConfig ¶
type ThresholdsConfig struct { Mode ThresholdsMode `json:"mode"` // Must be sorted by 'value', first value is always -Infinity Steps []Threshold `json:"steps"` }
ThresholdsConfig setup thresholds
type ThresholdsMode ¶
type ThresholdsMode string
ThresholdsMode absolute or percentage
const ( // ThresholdsModeAbsolute pick thresholds based on absolute value ThresholdsModeAbsolute ThresholdsMode = "absolute" // ThresholdsModePercentage the threshold is relative to min/max ThresholdsModePercentage ThresholdsMode = "percentage" )
type TimeSeriesSchema ¶
type TimeSeriesSchema struct { Type TimeSeriesType // the type of series, as determinted by frame.TimeSeriesSchema() TimeIndex int // Field index of the time series index TimeIsNullable bool // true if the time index is nullable (of *time.Time) ValueIndices []int // Field indices of value columns (All fields excluding string fields and the time index) FactorIndices []int // Field indices of string, *string, bool, or *bool Fields }
TimeSeriesSchema is information about a Frame's schema. It is populated from the Frame's TimeSeriesSchema() method.
type TimeSeriesType ¶
type TimeSeriesType int
TimeSeriesType represents the type of time series the schema can be treated as (if any).
const ( // TimeSeriesTypeNot means this Frame is not a valid time series. This means it lacks at least // one of a time Field and another (value) Field. TimeSeriesTypeNot TimeSeriesType = iota // TimeSeriesTypeLong means this Frame can be treated as a "Long" time series. // // A Long series has one or more string Fields, disregards Labels on Fields, and generally // repeated time values in the time index. TimeSeriesTypeLong // TimeSeriesTypeWide means this Frame can be treated as a "Wide" time series. // // A Wide series has no string fields, should not have repeated time values, and generally // uses labels. TimeSeriesTypeWide )
TODO: Create and link to Grafana documentation on Long vs Wide
func (TimeSeriesType) String ¶
func (t TimeSeriesType) String() string
type ValueMapper ¶ added in v0.98.0
type ValueMapper map[string]ValueMappingResult
ValueMapper converts one set of strings to another
type ValueMapping ¶
type ValueMapping interface {
// contains filtered or unexported methods
}
ValueMapping allows mapping input values to text and color
type ValueMappingResult ¶ added in v0.98.0
type ValueMappingResult struct { Text string `json:"text,omitempty"` Color string `json:"color,omitempty"` Index int `json:"index,omitempty"` // just used ofr ui ordering }
ValueMappingResult is the results from mapping a value
type ValueMappings ¶ added in v0.98.0
type ValueMappings []ValueMapping
func (ValueMappings) MarshalJSON ¶ added in v0.98.0
func (m ValueMappings) MarshalJSON() ([]byte, error)
MarshalJSON writes the results as json
func (*ValueMappings) UnmarshalJSON ¶ added in v0.98.0
func (m *ValueMappings) UnmarshalJSON(b []byte) error
UnmarshalJSON will read JSON into the appropriate go types
Source Files ¶
- arrow.go
- arrow_column_builders.go
- constants.go
- conversion_input.go
- field.go
- field_config.go
- field_type.go
- frame.go
- frame_json.gen.go
- frame_json.go
- frame_meta.go
- framer.go
- gen.go
- generic_nullable_vector.go
- generic_vector.go
- labels.go
- nullable_vector.gen.go
- time_series.go
- value_mapping.go
- vector.gen.go
- vector.go
Directories ¶
Path | Synopsis |
---|---|
Package converters provides data.FieldConverters commonly used by plugins.
|
Package converters provides data.FieldConverters commonly used by plugins. |
Package framestruct provides functions to convert from any type to *data.Frame or data.Frames
|
Package framestruct provides functions to convert from any type to *data.Frame or data.Frames |