-
Notifications
You must be signed in to change notification settings - Fork 23
/
dns_server.go
149 lines (133 loc) · 5.44 KB
/
dns_server.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
package thousandeyes
import (
"encoding/json"
"fmt"
)
// Server - a server ?
type Server struct {
ServerID *int64 `json:"serverId,omitempty"`
ServerName *string `json:"serverName,omitempty"`
}
// DNSServer - dns server test
type DNSServer 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"`
BandwidthMeasurements *bool `json:"bandwidthMeasurements,omitempty" te:"int-bool"`
BGPMeasurements *bool `json:"bgpMeasurements,omitempty" te:"int-bool"`
BGPMonitors *[]BGPMonitor `json:"bgpMonitors,omitempty"`
DNSServers *[]Server `json:"dnsServers,omitempty"`
DNSTransportProtocol *string `json:"dnsTransportProtocol,omitempty"`
Domain *string `json:"domain,omitempty"`
Interval *int `json:"interval,omitempty"`
MTUMeasurements *bool `json:"mtuMeasurements,omitempty" te:"int-bool"`
NetworkMeasurements *bool `json:"networkMeasurements,omitempty" te:"int-bool"`
NumPathTraces *int `json:"numPathTraces,omitempty"`
PathTraceMode *string `json:"pathTraceMode,omitempty"`
ProbeMode *string `json:"probeMode,omitempty"`
Protocol *string `json:"protocol,omitempty"`
RecursiveQueries *bool `json:"recursiveQueries,omitempty" te:"int-bool"`
UsePublicBGP *bool `json:"usePublicBgp,omitempty" te:"int-bool"`
}
// 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 DNSServer) MarshalJSON() ([]byte, error) {
type aliasTest DNSServer
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 *DNSServer) UnmarshalJSON(data []byte) error {
type aliasTest DNSServer
test := (*aliasTest)(t)
data, err := jsonIntToBool(t, data)
if err != nil {
return err
}
return json.Unmarshal(data, &test)
}
// AddAgent - Add dns server test
func (t *DNSServer) AddAgent(id int64) {
agent := Agent{AgentID: Int64(id)}
*t.Agents = append(*t.Agents, agent)
}
// AddAlertRule - Adds an alert to agent test
func (t *DNSServer) AddAlertRule(id int64) {
alertRule := AlertRule{RuleID: Int64(id)}
*t.AlertRules = append(*t.AlertRules, alertRule)
}
// GetDNSServer - get dns server test
func (c *Client) GetDNSServer(id int64) (*DNSServer, error) {
resp, err := c.get(fmt.Sprintf("/tests/%d", id))
if err != nil {
return &DNSServer{}, err
}
var target map[string][]DNSServer
if dErr := c.decodeJSON(resp, &target); dErr != nil {
return nil, fmt.Errorf("Could not decode JSON response: %v", dErr)
}
return &target["test"][0], nil
}
// CreateDNSServer - Create dns server test
func (c Client) CreateDNSServer(t DNSServer) (*DNSServer, error) {
resp, err := c.post("/tests/dns-server/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][]DNSServer
if dErr := c.decodeJSON(resp, &target); dErr != nil {
return nil, fmt.Errorf("Could not decode JSON response: %v", dErr)
}
return &target["test"][0], nil
}
// DeleteDNSServer - delete dns server test
func (c *Client) DeleteDNSServer(id int64) error {
resp, err := c.post(fmt.Sprintf("/tests/dns-server/%d/delete", id), nil, nil)
if err != nil {
return err
}
if resp.StatusCode != 204 {
return fmt.Errorf("failed to delete dns server test, response code %d", resp.StatusCode)
}
return nil
}
// UpdateDNSServer - - Update dns server test
func (c *Client) UpdateDNSServer(id int64, t DNSServer) (*DNSServer, error) {
resp, err := c.post(fmt.Sprintf("/tests/dns-server/%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][]DNSServer
if dErr := c.decodeJSON(resp, &target); dErr != nil {
return nil, fmt.Errorf("Could not decode JSON response: %v", dErr)
}
return &target["test"][0], nil
}