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
|
/*
* Datadog API for Go
*
* Please see the included LICENSE file for licensing information.
*
* Copyright 2013 by authors and contributors.
*/
package datadog
import (
"fmt"
"net/url"
"strconv"
)
// Event is a single event. If this is being used to post an event, then not
// all fields will be filled out.
type Event struct {
Id *int `json:"id,omitempty"`
Title *string `json:"title,omitempty"`
Text *string `json:"text,omitempty"`
Time *int `json:"date_happened,omitempty"` // UNIX time.
Priority *string `json:"priority,omitempty"`
AlertType *string `json:"alert_type,omitempty"`
Host *string `json:"host,omitempty"`
Aggregation *string `json:"aggregation_key,omitempty"`
SourceType *string `json:"source_type_name,omitempty"`
Tags []string `json:"tags,omitempty"`
Url *string `json:"url,omitempty"`
Resource *string `json:"resource,omitempty"`
EventType *string `json:"event_type,omitempty"`
}
// reqGetEvent is the container for receiving a single event.
type reqGetEvent struct {
Event *Event `json:"event,omitempty"`
}
// reqGetEvents is for returning many events.
type reqGetEvents struct {
Events []Event `json:"events,omitempty"`
}
// PostEvent takes as input an event and then posts it to the server.
func (client *Client) PostEvent(event *Event) (*Event, error) {
var out reqGetEvent
if err := client.doJsonRequest("POST", "/v1/events", event, &out); err != nil {
return nil, err
}
return out.Event, nil
}
// GetEvent gets a single event given an identifier.
func (client *Client) GetEvent(id int) (*Event, error) {
var out reqGetEvent
if err := client.doJsonRequest("GET", fmt.Sprintf("/v1/events/%d", id), nil, &out); err != nil {
return nil, err
}
return out.Event, nil
}
// GetEvents returns a slice of events from the query stream.
func (client *Client) GetEvents(start, end int,
priority, sources, tags string) ([]Event, error) {
// Since this is a GET request, we need to build a query string.
vals := url.Values{}
vals.Add("start", strconv.Itoa(start))
vals.Add("end", strconv.Itoa(end))
if priority != "" {
vals.Add("priority", priority)
}
if sources != "" {
vals.Add("sources", sources)
}
if tags != "" {
vals.Add("tags", tags)
}
// Now the request and response.
var out reqGetEvents
if err := client.doJsonRequest("GET",
fmt.Sprintf("/v1/events?%s", vals.Encode()), nil, &out); err != nil {
return nil, err
}
return out.Events, nil
}
|
