Skip to content

Commit ab4af57

Browse files
DerekBumDerekBum
committed
api: update all Update and Upsert requests
`Op` struct made private. Change all `Upsert` and `Update` requests to accept `*tarantool.Operations` as `ops` parameters instead of `interface{}`. Closes #348
1 parent 870ac45 commit ab4af57

13 files changed

+94
-100
lines changed

‎CHANGELOG.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,8 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release.
4949
constants for `protocol` (#337)
5050
- Change `crud` operations `Timeout` option type to `crud.OptFloat64`
5151
instead of `crud.OptUint` (#342)
52+
- Change all `Upsert` and `Update` requests to accept `*tarantool.Operations`
53+
as `ops` parameters instead of `interface{}` (#348)
5254

5355
### Deprecated
5456

‎README.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -255,7 +255,9 @@ is supported.
255255

256256
#### Client tools changes
257257

258+
* `Op` struct made private.
258259
* Remove `OpSplice` struct.
260+
* `Operations` struct made an instance of `msgpack.CustomEncoder` interface.
259261
* `Operations.Splice` method now accepts 5 arguments instead of 3.
260262

261263
## Contributing

‎client_tools.go

Lines changed: 11 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,8 @@ func (k IntIntKey) EncodeMsgpack(enc *msgpack.Encoder) error {
5454
return nil
5555
}
5656

57-
// Op - is update operation.
58-
type Op struct {
57+
// operation - is update operation.
58+
type operation struct {
5959
Op string
6060
Field int
6161
Arg interface{}
@@ -65,7 +65,7 @@ type Op struct {
6565
Replace string
6666
}
6767

68-
func (o Op) EncodeMsgpack(enc *msgpack.Encoder) error {
68+
func (o operation) EncodeMsgpack(enc *msgpack.Encoder) error {
6969
isSpliceOperation := o.Op == spliceOperator
7070
argsLen := 3
7171
if isSpliceOperation {
@@ -108,22 +108,26 @@ const (
108108

109109
// Operations is a collection of update operations.
110110
type Operations struct {
111-
ops []Op
111+
ops []operation
112+
}
113+
114+
func (ops *Operations) EncodeMsgpack(enc *msgpack.Encoder) error {
115+
return enc.Encode(ops.ops)
112116
}
113117

114118
// NewOperations returns a new empty collection of update operations.
115119
func NewOperations() *Operations {
116-
ops := new(Operations)
120+
ops := &Operations{[]operation{}}
117121
return ops
118122
}
119123

120124
func (ops *Operations) append(op string, field int, arg interface{}) *Operations {
121-
ops.ops = append(ops.ops, Op{Op: op, Field: field, Arg: arg})
125+
ops.ops = append(ops.ops, operation{Op: op, Field: field, Arg: arg})
122126
return ops
123127
}
124128

125129
func (ops *Operations) appendSplice(op string, field, pos, len int, replace string) *Operations {
126-
ops.ops = append(ops.ops, Op{Op: op, Field: field, Pos: pos, Len: len, Replace: replace})
130+
ops.ops = append(ops.ops, operation{Op: op, Field: field, Pos: pos, Len: len, Replace: replace})
127131
return ops
128132
}
129133

‎connector.go

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,10 +29,10 @@ type Connector interface {
2929
Delete(space, index interface{}, key interface{}) (*Response, error)
3030
// Deprecated: the method will be removed in the next major version,
3131
// use a UpdateRequest object + Do() instead.
32-
Update(space, index interface{}, key, ops interface{}) (*Response, error)
32+
Update(space, index interface{}, key interface{}, ops *Operations) (*Response, error)
3333
// Deprecated: the method will be removed in the next major version,
3434
// use a UpsertRequest object + Do() instead.
35-
Upsert(space interface{}, tuple, ops interface{}) (*Response, error)
35+
Upsert(space interface{}, tuple interface{}, ops *Operations) (*Response, error)
3636
// Deprecated: the method will be removed in the next major version,
3737
// use a CallRequest object + Do() instead.
3838
Call(functionName string, args interface{}) (*Response, error)
@@ -67,7 +67,8 @@ type Connector interface {
6767
DeleteTyped(space, index interface{}, key interface{}, result interface{}) error
6868
// Deprecated: the method will be removed in the next major version,
6969
// use a UpdateRequest object + Do() instead.
70-
UpdateTyped(space, index interface{}, key, ops interface{}, result interface{}) error
70+
UpdateTyped(space, index interface{}, key interface{}, ops *Operations,
71+
result interface{}) error
7172
// Deprecated: the method will be removed in the next major version,
7273
// use a CallRequest object + Do() instead.
7374
CallTyped(functionName string, args interface{}, result interface{}) error
@@ -100,10 +101,10 @@ type Connector interface {
100101
DeleteAsync(space, index interface{}, key interface{}) *Future
101102
// Deprecated: the method will be removed in the next major version,
102103
// use a UpdateRequest object + Do() instead.
103-
UpdateAsync(space, index interface{}, key, ops interface{}) *Future
104+
UpdateAsync(space, index interface{}, key interface{}, ops *Operations) *Future
104105
// Deprecated: the method will be removed in the next major version,
105106
// use a UpsertRequest object + Do() instead.
106-
UpsertAsync(space interface{}, tuple interface{}, ops interface{}) *Future
107+
UpsertAsync(space interface{}, tuple interface{}, ops *Operations) *Future
107108
// Deprecated: the method will be removed in the next major version,
108109
// use a CallRequest object + Do() instead.
109110
CallAsync(functionName string, args interface{}) *Future

‎export_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ func RefImplDeleteBody(enc *msgpack.Encoder, res SchemaResolver, space, index,
7878
// RefImplUpdateBody is reference implementation for filling of an update
7979
// request's body.
8080
func RefImplUpdateBody(enc *msgpack.Encoder, res SchemaResolver, space, index,
81-
key, ops interface{}) error {
81+
key interface{}, ops *Operations) error {
8282
spaceEnc, err := newSpaceEncoder(res, space)
8383
if err != nil {
8484
return err
@@ -93,7 +93,7 @@ func RefImplUpdateBody(enc *msgpack.Encoder, res SchemaResolver, space, index,
9393
// RefImplUpsertBody is reference implementation for filling of an upsert
9494
// request's body.
9595
func RefImplUpsertBody(enc *msgpack.Encoder, res SchemaResolver, space,
96-
tuple, ops interface{}) error {
96+
tuple interface{}, ops *Operations) error {
9797
spaceEnc, err := newSpaceEncoder(res, space)
9898
if err != nil {
9999
return err

‎pool/connection_pool.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -462,8 +462,8 @@ func (p *ConnectionPool) Delete(space, index interface{}, key interface{},
462462
//
463463
// Deprecated: the method will be removed in the next major version,
464464
// use a UpdateRequest object + Do() instead.
465-
func (p *ConnectionPool) Update(space, index interface{}, key, ops interface{},
466-
userMode ...Mode) (*tarantool.Response, error) {
465+
func (p *ConnectionPool) Update(space, index interface{}, key interface{},
466+
ops *tarantool.Operations, userMode ...Mode) (*tarantool.Response, error) {
467467
conn, err := p.getConnByMode(RW, userMode)
468468
if err != nil {
469469
return nil, err
@@ -477,8 +477,8 @@ func (p *ConnectionPool) Update(space, index interface{}, key, ops interface{},
477477
//
478478
// Deprecated: the method will be removed in the next major version,
479479
// use a UpsertRequest object + Do() instead.
480-
func (p *ConnectionPool) Upsert(space interface{}, tuple, ops interface{},
481-
userMode ...Mode) (*tarantool.Response, error) {
480+
func (p *ConnectionPool) Upsert(space interface{}, tuple interface{},
481+
ops *tarantool.Operations, userMode ...Mode) (*tarantool.Response, error) {
482482
conn, err := p.getConnByMode(RW, userMode)
483483
if err != nil {
484484
return nil, err
@@ -639,8 +639,8 @@ func (p *ConnectionPool) DeleteTyped(space, index interface{}, key interface{},
639639
//
640640
// Deprecated: the method will be removed in the next major version,
641641
// use a UpdateRequest object + Do() instead.
642-
func (p *ConnectionPool) UpdateTyped(space, index interface{}, key, ops interface{},
643-
result interface{}, userMode ...Mode) error {
642+
func (p *ConnectionPool) UpdateTyped(space, index interface{}, key interface{},
643+
ops *tarantool.Operations, result interface{}, userMode ...Mode) error {
644644
conn, err := p.getConnByMode(RW, userMode)
645645
if err != nil {
646646
return err
@@ -788,8 +788,8 @@ func (p *ConnectionPool) DeleteAsync(space, index interface{}, key interface{},
788788
//
789789
// Deprecated: the method will be removed in the next major version,
790790
// use a UpdateRequest object + Do() instead.
791-
func (p *ConnectionPool) UpdateAsync(space, index interface{}, key, ops interface{},
792-
userMode ...Mode) *tarantool.Future {
791+
func (p *ConnectionPool) UpdateAsync(space, index interface{}, key interface{},
792+
ops *tarantool.Operations, userMode ...Mode) *tarantool.Future {
793793
conn, err := p.getConnByMode(RW, userMode)
794794
if err != nil {
795795
return newErrorFuture(err)
@@ -803,8 +803,8 @@ func (p *ConnectionPool) UpdateAsync(space, index interface{}, key, ops interfac
803803
//
804804
// Deprecated: the method will be removed in the next major version,
805805
// use a UpsertRequest object + Do() instead.
806-
func (p *ConnectionPool) UpsertAsync(space interface{}, tuple interface{}, ops interface{},
807-
userMode ...Mode) *tarantool.Future {
806+
func (p *ConnectionPool) UpsertAsync(space interface{}, tuple interface{},
807+
ops *tarantool.Operations, userMode ...Mode) *tarantool.Future {
808808
conn, err := p.getConnByMode(RW, userMode)
809809
if err != nil {
810810
return newErrorFuture(err)

‎pool/connection_pool_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1964,7 +1964,7 @@ func TestUpsert(t *testing.T) {
19641964
// Mode is `RW` by default, we have only one RW instance (servers[2])
19651965
resp, err := connPool.Upsert(spaceName,
19661966
[]interface{}{"upsert_key", "upsert_value"},
1967-
[]interface{}{[]interface{}{"=", 1, "new_value"}})
1967+
tarantool.NewOperations().Assign(1, "new_value"))
19681968
require.Nilf(t, err, "failed to Upsert")
19691969
require.NotNilf(t, resp, "response is nil after Upsert")
19701970

@@ -1993,7 +1993,7 @@ func TestUpsert(t *testing.T) {
19931993
// PreferRW
19941994
resp, err = connPool.Upsert(
19951995
spaceName, []interface{}{"upsert_key", "upsert_value"},
1996-
[]interface{}{[]interface{}{"=", 1, "new_value"}}, pool.PreferRW)
1996+
tarantool.NewOperations().Assign(1, "new_value"), pool.PreferRW)
19971997

19981998
require.Nilf(t, err, "failed to Upsert")
19991999
require.NotNilf(t, resp, "response is nil after Upsert")
@@ -2056,7 +2056,7 @@ func TestUpdate(t *testing.T) {
20562056

20572057
// Mode is `RW` by default, we have only one RW instance (servers[2])
20582058
resp, err = connPool.Update(spaceName, indexNo,
2059-
[]interface{}{"update_key"}, []interface{}{[]interface{}{"=", 1, "new_value"}})
2059+
[]interface{}{"update_key"}, tarantool.NewOperations().Assign(1, "new_value"))
20602060
require.Nilf(t, err, "failed to Update")
20612061
require.NotNilf(t, resp, "response is nil after Update")
20622062

@@ -2085,7 +2085,7 @@ func TestUpdate(t *testing.T) {
20852085
// PreferRW
20862086
resp, err = connPool.Update(
20872087
spaceName, indexNo, []interface{}{"update_key"},
2088-
[]interface{}{[]interface{}{"=", 1, "another_value"}}, pool.PreferRW)
2088+
tarantool.NewOperations().Assign(1, "another_value"), pool.PreferRW)
20892089

20902090
require.Nilf(t, err, "failed to Update")
20912091
require.NotNilf(t, resp, "response is nil after Update")

‎pool/connector.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -106,16 +106,16 @@ func (c *ConnectorAdapter) Delete(space, index interface{},
106106
// Deprecated: the method will be removed in the next major version,
107107
// use a UpdateRequest object + Do() instead.
108108
func (c *ConnectorAdapter) Update(space, index interface{},
109-
key, ops interface{}) (*tarantool.Response, error) {
109+
key interface{}, ops *tarantool.Operations) (*tarantool.Response, error) {
110110
return c.pool.Update(space, index, key, ops, c.mode)
111111
}
112112

113113
// Upsert performs "update or insert" action of a tuple by key.
114114
//
115115
// Deprecated: the method will be removed in the next major version,
116116
// use a UpsertRequest object + Do() instead.
117-
func (c *ConnectorAdapter) Upsert(space interface{},
118-
tuple, ops interface{}) (*tarantool.Response, error) {
117+
func (c *ConnectorAdapter) Upsert(space, tuple interface{},
118+
ops *tarantool.Operations) (*tarantool.Response, error) {
119119
return c.pool.Upsert(space, tuple, ops, c.mode)
120120
}
121121

@@ -220,7 +220,7 @@ func (c *ConnectorAdapter) DeleteTyped(space, index interface{},
220220
// Deprecated: the method will be removed in the next major version,
221221
// use a UpdateRequest object + Do() instead.
222222
func (c *ConnectorAdapter) UpdateTyped(space, index interface{},
223-
key, ops interface{}, result interface{}) error {
223+
key interface{}, ops *tarantool.Operations, result interface{}) error {
224224
return c.pool.UpdateTyped(space, index, key, ops, result, c.mode)
225225
}
226226

@@ -314,16 +314,16 @@ func (c *ConnectorAdapter) DeleteAsync(space, index interface{},
314314
// Deprecated: the method will be removed in the next major version,
315315
// use a UpdateRequest object + Do() instead.
316316
func (c *ConnectorAdapter) UpdateAsync(space, index interface{},
317-
key, ops interface{}) *tarantool.Future {
317+
key interface{}, ops *tarantool.Operations) *tarantool.Future {
318318
return c.pool.UpdateAsync(space, index, key, ops, c.mode)
319319
}
320320

321321
// UpsertAsync sends "update or insert" action to Tarantool and returns Future.
322322
//
323323
// Deprecated: the method will be removed in the next major version,
324324
// use a UpsertRequest object + Do() instead.
325-
func (c *ConnectorAdapter) UpsertAsync(space interface{}, tuple interface{},
326-
ops interface{}) *tarantool.Future {
325+
func (c *ConnectorAdapter) UpsertAsync(space, tuple interface{},
326+
ops *tarantool.Operations) *tarantool.Future {
327327
return c.pool.UpsertAsync(space, tuple, ops, c.mode)
328328
}
329329

‎pool/connector_test.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ var reqIndex interface{} = []interface{}{2}
148148
var reqArgs interface{} = []interface{}{3}
149149
var reqTuple interface{} = []interface{}{4}
150150
var reqKey interface{} = []interface{}{5}
151-
var reqOps interface{} = []interface{}{6}
151+
var reqOps = tarantool.NewOperations()
152152

153153
var reqResult interface{} = []interface{}{7}
154154
var reqSqlInfo = tarantool.SQLInfo{AffectedCount: 3}
@@ -547,8 +547,8 @@ type updateMock struct {
547547
baseRequestMock
548548
}
549549

550-
func (m *updateMock) Update(space, index, key, ops interface{},
551-
mode ...Mode) (*tarantool.Response, error) {
550+
func (m *updateMock) Update(space, index, key interface{},
551+
ops *tarantool.Operations, mode ...Mode) (*tarantool.Response, error) {
552552
m.called++
553553
m.space = space
554554
m.index = index
@@ -578,8 +578,8 @@ type updateTypedMock struct {
578578
baseRequestMock
579579
}
580580

581-
func (m *updateTypedMock) UpdateTyped(space, index, key, ops interface{},
582-
result interface{}, mode ...Mode) error {
581+
func (m *updateTypedMock) UpdateTyped(space, index, key interface{},
582+
ops *tarantool.Operations, result interface{}, mode ...Mode) error {
583583
m.called++
584584
m.space = space
585585
m.index = index
@@ -610,8 +610,8 @@ type updateAsyncMock struct {
610610
baseRequestMock
611611
}
612612

613-
func (m *updateAsyncMock) UpdateAsync(space, index, key, ops interface{},
614-
mode ...Mode) *tarantool.Future {
613+
func (m *updateAsyncMock) UpdateAsync(space, index, key interface{},
614+
ops *tarantool.Operations, mode ...Mode) *tarantool.Future {
615615
m.called++
616616
m.space = space
617617
m.index = index
@@ -640,7 +640,7 @@ type upsertMock struct {
640640
baseRequestMock
641641
}
642642

643-
func (m *upsertMock) Upsert(space, tuple, ops interface{},
643+
func (m *upsertMock) Upsert(space, tuple interface{}, ops *tarantool.Operations,
644644
mode ...Mode) (*tarantool.Response, error) {
645645
m.called++
646646
m.space = space
@@ -669,8 +669,8 @@ type upsertAsyncMock struct {
669669
baseRequestMock
670670
}
671671

672-
func (m *upsertAsyncMock) UpsertAsync(space, tuple, ops interface{},
673-
mode ...Mode) *tarantool.Future {
672+
func (m *upsertAsyncMock) UpsertAsync(space, tuple interface{},
673+
ops *tarantool.Operations, mode ...Mode) *tarantool.Future {
674674
m.called++
675675
m.space = space
676676
m.tuple = tuple

‎pool/pooler.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -38,11 +38,11 @@ type Pooler interface {
3838
mode ...Mode) (*tarantool.Response, error)
3939
// Deprecated: the method will be removed in the next major version,
4040
// use a UpdateRequest object + Do() instead.
41-
Update(space, index interface{}, key, ops interface{},
41+
Update(space, index interface{}, key interface{}, ops *tarantool.Operations,
4242
mode ...Mode) (*tarantool.Response, error)
4343
// Deprecated: the method will be removed in the next major version,
4444
// use a UpsertRequest object + Do() instead.
45-
Upsert(space interface{}, tuple, ops interface{},
45+
Upsert(space interface{}, tuple interface{}, ops *tarantool.Operations,
4646
mode ...Mode) (*tarantool.Response, error)
4747
// Deprecated: the method will be removed in the next major version,
4848
// use a CallRequest object + Do() instead.
@@ -87,8 +87,8 @@ type Pooler interface {
8787
mode ...Mode) error
8888
// Deprecated: the method will be removed in the next major version,
8989
// use a UpdateRequest object + Do() instead.
90-
UpdateTyped(space, index interface{}, key, ops interface{},
91-
result interface{}, mode ...Mode) error
90+
UpdateTyped(space, index interface{}, key interface{},
91+
ops *tarantool.Operations, result interface{}, mode ...Mode) error
9292
// Deprecated: the method will be removed in the next major version,
9393
// use a CallRequest object + Do() instead.
9494
CallTyped(functionName string, args interface{}, result interface{},
@@ -128,11 +128,11 @@ type Pooler interface {
128128
mode ...Mode) *tarantool.Future
129129
// Deprecated: the method will be removed in the next major version,
130130
// use a UpdateRequest object + Do() instead.
131-
UpdateAsync(space, index interface{}, key, ops interface{},
132-
mode ...Mode) *tarantool.Future
131+
UpdateAsync(space, index interface{}, key interface{},
132+
ops *tarantool.Operations, mode ...Mode) *tarantool.Future
133133
// Deprecated: the method will be removed in the next major version,
134134
// use a UpsertRequest object + Do() instead.
135-
UpsertAsync(space interface{}, tuple interface{}, ops interface{},
135+
UpsertAsync(space interface{}, tuple interface{}, ops *tarantool.Operations,
136136
mode ...Mode) *tarantool.Future
137137
// Deprecated: the method will be removed in the next major version,
138138
// use a CallRequest object + Do() instead.

0 commit comments

Comments
 (0)