forked from thousandeyes/thousandeyes-sdk-go
-
Notifications
You must be signed in to change notification settings - Fork 0
/
dns_trace.go
131 lines (116 loc) · 4.33 KB
/
dns_trace.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
package thousandeyes
import (
"encoding/json"
"fmt"
)
// DNSTrace - DNS trace test
type DNSTrace struct {
// Common test fields
AlertsEnabled *bool `json:"alertsEnabled,omitempty" te:"int-bool"`
AlertRules *[]AlertRule `json:"alertRules,omitempty"`
APILinks *[]APILink `json:"apiLinks,omitempty"`
CreatedBy *string `json:"createdBy,omitempty"`
CreatedDate *string `json:"createdDate,omitempty"`
Description *string `json:"description,omitempty"`
Enabled *bool `json:"enabled,omitempty" te:"int-bool"`
Groups *[]GroupLabel `json:"groups,omitempty"`
ModifiedBy *string `json:"modifiedBy,omitempty"`
ModifiedDate *string `json:"modifiedDate,omitempty"`
SavedEvent *bool `json:"savedEvent,omitempty" te:"int-bool"`
SharedWithAccounts *[]SharedWithAccount `json:"sharedWithAccounts,omitempty"`
TestID *int64 `json:"testId,omitempty"`
TestName *string `json:"testName,omitempty"`
Type *string `json:"type,omitempty"`
LiveShare *bool `json:"liveShare,omitempty" te:"int-bool"`
// Fields unique to this test
Agents *[]Agent `json:"agents,omitempty"`
DNSTransportProtocol *string `json:"dnsTransportProtocol,omitempty"`
Domain *string `json:"domain,omitempty"`
Interval *int `json:"interval,omitempty"`
}
// MarshalJSON implements the json.Marshaler interface. It ensures
// that ThousandEyes int fields that only use the values 0 or 1 are
// treated as booleans.
func (t DNSTrace) MarshalJSON() ([]byte, error) {
type aliasTest DNSTrace
data, err := json.Marshal((aliasTest)(t))
if err != nil {
return nil, err
}
return jsonBoolToInt(&t, data)
}
// UnmarshalJSON implements the json.Unmarshaler interface. It ensures
// that ThousandEyes int fields that only use the values 0 or 1 are
// treated as booleans.
func (t *DNSTrace) UnmarshalJSON(data []byte) error {
type aliasTest DNSTrace
test := (*aliasTest)(t)
data, err := jsonIntToBool(t, data)
if err != nil {
return err
}
return json.Unmarshal(data, &test)
}
// AddAgent - Add agent to DNS Trace test
func (t *DNSTrace) AddAgent(id int) {
agent := Agent{AgentID: Int(id)}
*t.Agents = append(*t.Agents, agent)
}
// AddAlertRule - Adds an alert to agent test
func (t *DNSTrace) AddAlertRule(id int) {
alertRule := AlertRule{RuleID: Int(id)}
*t.AlertRules = append(*t.AlertRules, alertRule)
}
// GetDNSTrace - get dns trace test
func (c *Client) GetDNSTrace(id int) (*DNSTrace, error) {
resp, err := c.get(fmt.Sprintf("/tests/%d", id))
if err != nil {
return &DNSTrace{}, err
}
var target map[string][]DNSTrace
if dErr := c.decodeJSON(resp, &target); dErr != nil {
return nil, fmt.Errorf("Could not decode JSON response: %v", dErr)
}
return &target["test"][0], nil
}
// CreateDNSTrace - Create dns trace test
func (c Client) CreateDNSTrace(t DNSTrace) (*DNSTrace, error) {
resp, err := c.post("/tests/dns-trace/new", t, nil)
if err != nil {
return &t, err
}
if resp.StatusCode != 201 {
return &t, fmt.Errorf("failed to create test, response code %d", resp.StatusCode)
}
var target map[string][]DNSTrace
if dErr := c.decodeJSON(resp, &target); dErr != nil {
return nil, fmt.Errorf("Could not decode JSON response: %v", dErr)
}
return &target["test"][0], nil
}
//DeleteDNSTrace - delete dns trace test
func (c *Client) DeleteDNSTrace(id int) error {
resp, err := c.post(fmt.Sprintf("/tests/dns-trace/%d/delete", id), nil, nil)
if err != nil {
return err
}
if resp.StatusCode != 204 {
return fmt.Errorf("failed to delete dns trace test, response code %d", resp.StatusCode)
}
return nil
}
//UpdateDNSTrace - update dns trace test
func (c *Client) UpdateDNSTrace(id int, t DNSTrace) (*DNSTrace, error) {
resp, err := c.post(fmt.Sprintf("/tests/dns-trace/%d/update", id), t, nil)
if err != nil {
return &t, err
}
if resp.StatusCode != 200 {
return &t, fmt.Errorf("failed to update test, response code %d", resp.StatusCode)
}
var target map[string][]DNSTrace
if dErr := c.decodeJSON(resp, &target); dErr != nil {
return nil, fmt.Errorf("Could not decode JSON response: %v", dErr)
}
return &target["test"][0], nil
}