forked from spaceapegames/go-wavefront
-
Notifications
You must be signed in to change notification settings - Fork 12
/
dashboard.go
375 lines (313 loc) · 14.4 KB
/
dashboard.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
package wavefront
import (
"encoding/json"
"fmt"
"strconv"
)
// Dashboard represents a single Wavefront Dashboard
type Dashboard struct {
// Name is the name given to an Dashboard
Name string `json:"name"`
// ID is the Wavefront-assigned ID of an existing Dashboard
ID string `json:"id"`
// Tags are the tags applied to the Dashboard
Tags []string `json:"-"`
// Description is a description given to the Dashboard
Description string `json:"description"`
// Url is the relative url to access the dashboard by on a cluster
Url string `json:"url"`
// Sections is an array of Section that split up the dashboard
Sections []Section `json:"sections"`
// Access Control Lists for who can view or modify (user or group IDs)
ACL AccessControlList `json:"acl"`
// Additional dashboard settings
ChartTitleBgColor string `json:"chartTitleBgColor,omitempty"`
ChartTitleColor string `json:"chartTitleColor,omitempty"`
ChartTitleScalar int `json:"chartTitleScalar,omitempty"`
DefaultEndTime int `json:"defaultEndTime,omitempty"`
DefaultStartTime int `json:"defaultStartTime,omitempty"`
DefaultTimeWindow string `json:"defaultTimeWindow"`
DisplayDescription bool `json:"displayDescription"`
DisplayQueryParameters bool `json:"displayQueryParameters"`
DisplaySectionTableOfContents bool `json:"displaySectionTableOfContents"`
EventFilterType string `json:"eventFilterType"`
EventQuery string `json:"eventQuery"`
Favorite bool `json:"favorite"`
// Additional dashboard information
Customer string `json:"customer,omitempty"`
Deleted bool `json:"deleted,omitempty"`
Hidden bool `json:"hidden,omitempty"`
NumCharts int `json:"numCharts,omitempty"`
NumFavorites int `json:"numFavorites,omitempty"`
CreatorId string `json:"creatorId,omitempty"`
UpdaterId string `json:"updaterId,omitempty"`
SystemOwned bool `json:"systemOwned,omitempty"`
ViewsLastDay int `json:"viewsLastDay,omitempty"`
ViewsLastMonth int `json:"viewsLastMonth,omitempty"`
ViewsLastWeek int `json:"viewsLastWeek,omitempty"`
CreatedEpochMillis int64 `json:"createdEpochMillis,omitempty"`
UpdatedEpochMillis int64 `json:"updatedEpochMillis,omitempty"`
// Parameters (reserved - usage unknown at this time)
Parameters struct{} `json:"parameters"`
// ParameterDetails sets variables that can be used within queries
ParameterDetails map[string]ParameterDetail `json:"parameterDetails"`
}
// ParameterDetail represents a parameter to dashboard that can be consumed in queries
type ParameterDetail struct {
// Label represents the name of the variable
Label string `json:"label"`
// DefaultValue maps to keys in the map ValuesToReadableStrings
DefaultValue string `json:"defaultValue"`
// HideFromView Whether to hide from the view of the user viewing the Dashboard
HideFromView bool `json:"hideFromView"`
// ParameterType (SIMPLE, LIST, DYNAMIC)
ParameterType string `json:"parameterType"`
// ValuesToReadableStrings
ValuesToReadableStrings map[string]string `json:"valuesToReadableStrings"`
// QueryValue
QueryValue string `json:"queryValue,omitempty"`
// TagKey Only required for a DynamicFieldType of TAG_KEY
TagKey string `json:"tagKey,omitempty"`
// DynamicFieldType (TAG_KEY, MATCHING_SOURCE_TAG, SOURCE_TAG, SOURCE, METRIC_NAME)
// Only required for a Parameter type of Dynamic.
DynamicFieldType string `json:"dynamicFieldType,omitempty"`
}
// Section Represents a Single section within a Dashboard
type Section struct {
// Name is the name given to this section
Name string `json:"name"`
// Rows is an array of Rows in this section
Rows []Row `json:"rows"`
}
// Row represents a single Row withing a Section of a Wavefront Dashboard
type Row struct {
// Name represents the display name of the Row
Name string `json:"name"`
// HeightFactor sets the height of the Row
HeightFactor int `json:"heightFactor"`
// Charts is an array of Chart that this row contains
Charts []Chart `json:"charts"`
}
// Chart represents a single Chart, on a single Row with in Section of a Wavefront Dashboard
type Chart struct {
// Name is the name of a chart
Name string `json:"name"`
// Description is the description of the chart
Description string `json:"description"`
// Base (unknown usage, defaults to 1)
Base int `json:"base"`
// Include obsolete metrics older than 4 weeks ago into the current time window
IncludeObsoleteMetrics bool `json:"includeObsoleteMetrics"`
// Interpolate points that existed in the past /future into the current time window
InterpolatePoints bool `json:"interpolatePoints"`
// Don't include default events on the chart
NoDefaultEvents bool `json:"noDefaultEvents"`
// Strategy to use when aggregating metric points (LAST, AVERAGE, COUNT, etc)
Summarization string `json:"summarization,omitempty"`
// Sources is an Array of Source
Sources []Source `json:"sources"`
// Units are the units to use for the y-axis
Units string `json:"units,omitempty"`
// ChartSettings are custom settings for the chart
ChartSettings ChartSetting `json:"chartSettings"`
// ChartAttributes is arbitrary JSON used to configure a chart's attributes
ChartAttributes json.RawMessage `json:"chartAttributes,omitempty"`
}
// Source represents a single Source for a Chart
type Source struct {
// Name is the name given to the source
Name string `json:"name"`
// Query is a wavefront Query
Query string `json:"query"`
// Disabled indicated whether the source is disabled from being rendered on the chart
Disabled bool `json:"disabled,omitempty"`
// ScatterPlotSource
ScatterPlotSource string `json:"scatterPlotSource,omitempty"`
// QuerybuilderEnabled
QuerybuilderEnabled bool `json:"querybuilderEnabled"`
// SourceDescription
SourceDescription string `json:"sourceDescription"`
// SourceColor
SourceColor string `json:"sourceColor,omitempty"`
// SecondaryAxis
SecondaryAxis bool `json:"secondaryAxis,omitempty"`
}
// ChartSetting represents various custom settings for a Chart
type ChartSetting struct {
AutoColumnTags bool `json:"autoColumnTags,omitempty"`
ColumnTags string `json:"columnTags,omitempty"`
CustomTags []string `json:"customTags,omitempty"`
ExpectedDataSpacing int `json:"expectedDataSpacing,omitempty"`
FixedLegendDisplayStats []string `json:"fixedLegendDisplayStats,omitempty"`
FixedLegendEnabled bool `json:"fixedLegendEnabled,omitempty"`
FixedLegendFilterField string `json:"fixedLegendFilterField,omitempty"`
FixedLegendFilterLimit int `json:"fixedLegendFilterLimit,omitempty"`
FixedLegendFilterSort string `json:"fixedLegendFilterSort,omitempty"`
FixedLegendHideLabel bool `json:"fixedLegendHideLabel,omitempty"`
FixedLegendPosition string `json:"fixedLegendPosition,omitempty"`
FixedLegendUseRawStats bool `json:"fixedLegendUseRawStats,omitempty"`
GroupBySource bool `json:"groupBySource,omitempty"`
InvertDynamicLegendHoverControl bool `json:"invertDynamicLegendHoverControl,omitempty"`
LineType string `json:"lineType,omitempty"`
Max float32 `json:"max,omitempty"`
Min float32 `json:"min,omitempty"`
NumTags int `json:"numTags,omitempty"`
PlainMarkdownContent string `json:"plainMarkdownContent,omitempty"`
ShowHosts bool `json:"showHosts,omitempty"`
ShowLabels bool `json:"showLabels,omitempty"`
ShowRawValues bool `json:"showRawValues,omitempty"`
SortValuesDescending bool `json:"sortValuesDescending,omitempty"`
SparklineDecimalPrecision int `json:"sparklineDecimalPrecision"`
SparklineDisplayColor string `json:"sparklineDisplayColor,omitempty"`
SparklineDisplayFontSize string `json:"sparklineDisplayFontSize,omitempty"`
SparklineDisplayHorizontalPosition string `json:"sparklineDisplayHorizontalPosition,omitempty"`
SparklineDisplayPostfix string `json:"sparklineDisplayPostfix,omitempty"`
SparklineDisplayPrefix string `json:"sparklineDisplayPrefix,omitempty"`
SparklineDisplayValueType string `json:"sparklineDisplayValueType,omitempty"`
SparklineDisplayVerticalPosition string `json:"sparklineDisplayVerticalPosition,omitempty"`
SparklineFillColor string `json:"sparklineFillColor,omitempty"`
SparklineLineColor string `json:"sparklineLineColor,omitempty"`
SparklineSize string `json:"sparklineSize,omitempty"`
SparklineValueColorMapApplyTo string `json:"sparklineValueColorMapApplyTo,omitempty"`
SparklineValueColorMapColors []string `json:"sparklineValueColorMapColors,omitempty"`
SparklineValueColorMapValues []int `json:"sparklineValueColorMapValues,omitempty"`
SparklineValueColorMapValuesV2 []float32 `json:"sparklineValueColorMapValuesV2,omitempty"`
SparklineValueTextMapText []string `json:"sparklineValueTextMapText,omitempty"`
SparklineValueTextMapThresholds []float32 `json:"sparklineValueTextMapThresholds,omitempty"`
StackType string `json:"stackType,omitempty"`
TagMode string `json:"tagMode,omitempty"`
TimeBasedColoring bool `json:"timeBasedColoring,omitempty"`
Type string `json:"type,omitempty"`
Windowing string `json:"windowing,omitempty"`
WindowSize int `json:"windowSize,omitempty"`
Xmax float32 `json:"xmax,omitempty"`
Xmin float32 `json:"xmin,omitempty"`
Y0ScaleSIBy1024 bool `json:"y0ScaleSIBy1024,omitempty"`
Y0UnitAutoscaling bool `json:"y0UnitAutoscaling,omitempty"`
Y1Max float32 `json:"y1Max,omitempty"`
Y1Min float32 `json:"y1Min,omitempty"`
Y1ScaleSIBy1024 bool `json:"y1ScaleSIBy1024,omitempty"`
Y1UnitAutoscaling bool `json:"y1UnitAutoscaling,omitempty"`
Y1Units string `json:"y1Units,omitempty"`
Ymax float32 `json:"ymax,omitempty"`
Ymin float32 `json:"ymin,omitempty"`
}
// Dashboards is used to perform Dashboard-related operations against the Wavefront API
type Dashboards struct {
// client is the Wavefront client used to perform Dashboard-related operations
client Wavefronter
}
const baseDashboardPath = "/api/v2/dashboard"
// UnmarshalJSON is a custom JSON unmarshaller for a Dashboard, used to
// populate the Tags field in a more intuitive fashion
func (d *Dashboard) UnmarshalJSON(b []byte) error {
type tags struct {
CustomerTags []string `json:"customerTags,omitempty"`
}
type dashboard Dashboard
temp := struct {
Tags tags `json:"tags,omitempty"`
*dashboard
}{
dashboard: (*dashboard)(d),
}
if err := json.Unmarshal(b, &temp); err != nil {
return err
}
d.Tags = temp.Tags.CustomerTags
return nil
}
func (d *Dashboard) MarshalJSON() ([]byte, error) {
type tags struct {
CustomerTags []string `json:"customerTags,omitempty"`
}
type dashboard Dashboard
return json.Marshal(&struct {
Tags *tags `json:"tags,omitempty"`
*dashboard
}{
Tags: &tags{CustomerTags: d.Tags},
dashboard: (*dashboard)(d),
})
}
// Dashboards is used to return a client for Dashboard-related operations
func (c *Client) Dashboards() *Dashboards {
return &Dashboards{client: c}
}
// Find returns all Dashboards filtered by the given search conditions.
// If filter is nil, all Dashboards are returned.
func (d Dashboards) Find(filter []*SearchCondition) (
results []*Dashboard, err error) {
err = doSearch(filter, "dashboard", d.client, &results)
return
}
// Create is used to create an Dashboard in Wavefront.
// If successful, the ID field of the Dashboard will be populated.
func (d Dashboards) Create(dashboard *Dashboard) error {
return doRest(
"POST",
baseDashboardPath,
d.client,
doPayload(dashboard),
doResponse(dashboard))
}
// Update is used to update an existing Dashboard.
// The ID field of the Dashboard must be populated
func (d Dashboards) Update(dashboard *Dashboard) error {
if dashboard.ID == "" {
return fmt.Errorf("dashboard id field not set")
}
return doRest(
"PUT",
fmt.Sprintf("%s/%s", baseDashboardPath, dashboard.ID),
d.client,
doPayload(dashboard),
doResponse(dashboard))
}
// Get is used to retrieve an existing Dashboard by ID.
// The ID field must be provided
func (d Dashboards) Get(dashboard *Dashboard) error {
if dashboard.ID == "" {
return fmt.Errorf("dashboard id field is not set")
}
return doRest(
"GET",
fmt.Sprintf("%s/%s", baseDashboardPath, dashboard.ID),
d.client,
doResponse(dashboard))
}
// Delete is used to delete an existing Dashboard.
// The ID field of the Dashboard must be populated
func (d Dashboards) Delete(dashboard *Dashboard, skipTrash bool) error {
if dashboard.ID == "" {
return fmt.Errorf("dashboard id field not set")
}
params := map[string]string{
"skipTrash": strconv.FormatBool(skipTrash),
}
err := doRest(
"DELETE",
fmt.Sprintf("%s/%s", baseDashboardPath, dashboard.ID),
d.client,
doParams(params))
if err != nil {
return err
}
//reset the ID field so deletion is not attempted again
dashboard.ID = ""
return nil
}
// SetTags Set Tags is used to set the tags on an existing dashboard
func (d Dashboards) SetTags(id string, tags []string) error {
return doRest(
"POST",
fmt.Sprintf("%s/%s/tag", baseDashboardPath, id),
d.client,
doPayload(tags))
}
// SetACL Sets the ACL on the dashboard with the supplied list of IDs for canView and canModify
// an empty []string on canView will remove all values set
// an empty []string on canModify will set the value to the owner of the token issuing the API call
func (d Dashboards) SetACL(id string, canView, canModify []string) error {
return putEntityACL(id, canView, canModify, baseDashboardPath, d.client)
}