forked from fl00r/go-tarantool-1.6
-
Notifications
You must be signed in to change notification settings - Fork 60
/
Copy pathdelete.go
65 lines (54 loc) · 1.54 KB
/
delete.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 crud
import (
"context"
"github.com/tarantool/go-tarantool"
)
// DeleteOpts describes options for `crud.delete` method.
type DeleteOpts = SimpleOperationOpts
// DeleteRequest helps you to create request object to call `crud.delete`
// for execution by a Connection.
type DeleteRequest struct {
spaceRequest
key Tuple
opts DeleteOpts
}
type deleteArgs struct {
_msgpack struct{} `msgpack:",asArray"` //nolint: structcheck,unused
Space string
Key Tuple
Opts DeleteOpts
}
// MakeDeleteRequest returns a new empty DeleteRequest.
func MakeDeleteRequest(space string) DeleteRequest {
req := DeleteRequest{}
req.impl = newCall("crud.delete")
req.space = space
req.opts = DeleteOpts{}
return req
}
// Key sets the key for the DeleteRequest request.
// Note: default value is nil.
func (req DeleteRequest) Key(key Tuple) DeleteRequest {
req.key = key
return req
}
// Opts sets the options for the DeleteRequest request.
// Note: default value is nil.
func (req DeleteRequest) Opts(opts DeleteOpts) DeleteRequest {
req.opts = opts
return req
}
// Body fills an encoder with the call request body.
func (req DeleteRequest) Body(res tarantool.SchemaResolver, enc *encoder) error {
if req.key == nil {
req.key = []interface{}{}
}
args := deleteArgs{Space: req.space, Key: req.key, Opts: req.opts}
req.impl = req.impl.Args(args)
return req.impl.Body(res, enc)
}
// Context sets a passed context to CRUD request.
func (req DeleteRequest) Context(ctx context.Context) DeleteRequest {
req.impl = req.impl.Context(ctx)
return req
}