forked from ravendb/ravendb-go-client
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathget_statistics_operation.go
65 lines (49 loc) · 1.26 KB
/
get_statistics_operation.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
package ravendb
import (
"net/http"
)
var (
_ IMaintenanceOperation = &GetStatisticsOperation{}
)
type GetStatisticsOperation struct {
debugTag string
Command *GetStatisticsCommand
}
func NewGetStatisticsOperation(debugTag string) *GetStatisticsOperation {
return &GetStatisticsOperation{
debugTag: debugTag,
}
}
func (o *GetStatisticsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error) {
o.Command = NewGetStatisticsCommand(o.debugTag)
return o.Command, nil
}
var (
_ RavenCommand = &GetStatisticsCommand{}
)
type GetStatisticsCommand struct {
RavenCommandBase
debugTag string
Result *DatabaseStatistics
}
func NewGetStatisticsCommand(debugTag string) *GetStatisticsCommand {
cmd := &GetStatisticsCommand{
RavenCommandBase: NewRavenCommandBase(),
debugTag: debugTag,
}
cmd.IsReadRequest = true
return cmd
}
func (c *GetStatisticsCommand) CreateRequest(node *ServerNode) (*http.Request, error) {
url := node.URL + "/databases/" + node.Database + "/stats"
if c.debugTag != "" {
url += "?" + c.debugTag
}
return newHttpGet(url)
}
func (c *GetStatisticsCommand) SetResponse(response []byte, fromCache bool) error {
if len(response) == 0 {
return throwInvalidResponse()
}
return jsonUnmarshal(response, &c.Result)
}