forked from ravendb/ravendb-go-client
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathreset_index_operation.go
61 lines (47 loc) · 1.29 KB
/
reset_index_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
package ravendb
import (
"net/http"
)
var _ IVoidMaintenanceOperation = &ResetIndexOperation{}
type ResetIndexOperation struct {
indexName string
Command *ResetIndexCommand
}
func NewResetIndexOperation(indexName string) (*ResetIndexOperation, error) {
if indexName == "" {
return nil, newIllegalArgumentError("indexName cannot be empty")
}
return &ResetIndexOperation{
indexName: indexName,
}, nil
}
func (o *ResetIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error) {
var err error
o.Command, err = NewResetIndexCommand(o.indexName)
if err != nil {
return nil, err
}
return o.Command, nil
}
var (
_ RavenCommand = &ResetIndexCommand{}
)
type ResetIndexCommand struct {
RavenCommandBase
indexName string
}
func NewResetIndexCommand(indexName string) (*ResetIndexCommand, error) {
if indexName == "" {
return nil, newIllegalArgumentError("indexName cannot be empty")
}
cmd := &ResetIndexCommand{
RavenCommandBase: NewRavenCommandBase(),
indexName: indexName,
}
cmd.ResponseType = RavenCommandResponseTypeEmpty
return cmd, nil
}
func (c *ResetIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error) {
url := node.URL + "/databases/" + node.Database + "/indexes?name=" + urlUtilsEscapeDataString(c.indexName)
return newHttpReset(url)
}