api: add CRUD module support

This patch provides crud [1] methods as request objects to support CRUD API.
The following methods are supported:

* `insert`
* `insert_object`
* `insert_many`
* `insert_object_many`
* `get`
* `update`
* `delete`
* `replace`
* `replace_object`
* `replace_many`
* `replace_object_many`
* `upsert`
* `upsert_object`
* `upsert_many`
* `upsert_object_many`
* `select`
* `min`
* `max`
* `truncate`
* `len`
* `storage_info`
* `count`
* `stats`
* `unflatten_rows`

1. https://github.com/tarantool/crud

Closes #108

Author: AnaNek

CHANGELOG.md

@@ -12,6 +12,7 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release.
 
 - Support pagination (#246)
 - A Makefile target to test with race detector (#218)
+- Support CRUD API (#108)
 
 ### Changed
 

Makefile

@@ -21,12 +21,13 @@ endif
 
 .PHONY: clean
 clean:
-	( cd ./queue; rm -rf .rocks )
+	( rm -rf queue/.rocks crud/.rocks )
 	rm -f $(COVERAGE_FILE)
 
 .PHONY: deps
 deps: clean
 	( cd ./queue/testdata; $(TTCTL) rocks install queue 1.2.1 )
+	( cd ./crud; $(TTCTL) rocks install crud 0.14.1 )
 
 .PHONY: datetime-timezones
 datetime-timezones:
@@ -99,6 +100,13 @@ test-settings:
 	go clean -testcache
 	go test -tags "$(TAGS)" ./settings/ -v -p 1
 
+.PHONY: test-crud
+test-crud:
+	@echo "Running tests in crud package"
+	cd ./crud/ && tarantool -e "require('crud')"
+	go clean -testcache
+	go test -tags "$(TAGS)" ./crud/ -v -p 1
+
 .PHONY: test-main
 test-main:
 	@echo "Running tests in main package"

crud/common.go

@@ -0,0 +1,42 @@
+package crud
+
+import (
+	"context"
+
+	"github.com/tarantool/go-tarantool"
+)
+
+type Tuple = []interface{}
+type Object = map[string]interface{}
+
+type baseRequest struct {
+	impl *tarantool.CallRequest
+}
+
+func (req *baseRequest) initImpl(methodName string) {
+	req.impl = tarantool.NewCall17Request(methodName)
+}
+
+// Code returns IPROTO code for CRUD request.
+func (req *baseRequest) Code() int32 {
+	return req.impl.Code()
+}
+
+// Ctx returns a context of CRUD request.
+func (req *baseRequest) Ctx() context.Context {
+	return req.impl.Ctx()
+}
+
+// Async returns is CRUD request expects a response.
+func (req *baseRequest) Async() bool {
+	return req.impl.Async()
+}
+
+type spaceRequest struct {
+	baseRequest
+	space string
+}
+
+func (req *spaceRequest) setSpace(space string) {
+	req.space = space
+}

crud/conditions.go

@@ -0,0 +1,20 @@
+package crud
+
+type Operator string
+
+const (
+	EQ Operator = "="
+	LT Operator = "<"
+	LE Operator = "<="
+	GT Operator = ">"
+	GE Operator = ">="
+)
+
+type Condition struct {
+	// Instruct msgpack to pack this struct as array, so no custom packer
+	// is needed.
+	_msgpack struct{} `msgpack:",asArray"` //nolint: structcheck,unused
+	Operator Operator
+	KeyName  string
+	KeyValue interface{}
+}

crud/count.go

@@ -0,0 +1,88 @@
+package crud
+
+import (
+	"context"
+
+	"github.com/tarantool/go-tarantool"
+)
+
+type CountOpts struct {
+	Timeout       OptUint
+	VshardRouter  OptString
+	Mode          OptString
+	PreferReplica OptBool
+	Balance       OptBool
+	YieldEvery    OptUint
+	BucketId      OptUint
+	ForceMapCall  OptBool
+	Fullscan      OptBool
+}
+
+func (opts CountOpts) EncodeMsgpack(enc *encoder) error {
+	const optsCnt = 9
+
+	options := []option{opts.Timeout, opts.VshardRouter,
+		opts.Mode, opts.PreferReplica, opts.Balance,
+		opts.YieldEvery, opts.BucketId, opts.ForceMapCall,
+		opts.Fullscan}
+	names := []string{timeoutOptName, vshardRouterOptName,
+		modeOptName, preferReplicaOptName, balanceOptName,
+		yieldEveryOptName, bucketIdOptName, forceMapCallOptName,
+		fullscanOptName}
+	values := make([]interface{}, optsCnt)
+
+	return encodeOptions(enc, options, names, values)
+}
+
+// CountRequest helps you to create request object to call `crud.count`
+// for execution by a Connection.
+type CountRequest struct {
+	spaceRequest
+	conditions []Condition
+	opts       CountOpts
+}
+
+type countArgs struct {
+	_msgpack   struct{} `msgpack:",asArray"` //nolint: structcheck,unused
+	Space      string
+	Conditions []Condition
+	Opts       CountOpts
+}
+
+// NewCountRequest returns a new empty CountRequest.
+func NewCountRequest(space string) *CountRequest {
+	req := new(CountRequest)
+	req.initImpl("crud.count")
+	req.setSpace(space)
+	req.conditions = []Condition{}
+	req.opts = CountOpts{}
+	return req
+}
+
+// Conditions sets the conditions for the CountRequest request.
+// Note: default value is nil.
+func (req *CountRequest) Conditions(conditions []Condition) *CountRequest {
+	req.conditions = conditions
+	return req
+}
+
+// Opts sets the options for the CountRequest request.
+// Note: default value is nil.
+func (req *CountRequest) Opts(opts CountOpts) *CountRequest {
+	req.opts = opts
+	return req
+}
+
+// Body fills an encoder with the call request body.
+func (req *CountRequest) Body(res tarantool.SchemaResolver, enc *encoder) error {
+	args := countArgs{Space: req.space, Conditions: req.conditions, 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 *CountRequest) Context(ctx context.Context) *CountRequest {
+	req.impl = req.impl.Context(ctx)
+
+	return req
+}

crud/delete.go

@@ -0,0 +1,62 @@
+package crud
+
+import (
+	"context"
+
+	"github.com/tarantool/go-tarantool"
+)
+
+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
+}
+
+// NewDeleteRequest returns a new empty DeleteRequest.
+func NewDeleteRequest(space string) *DeleteRequest {
+	req := new(DeleteRequest)
+	req.initImpl("crud.delete")
+	req.setSpace(space)
+	req.key = Tuple{}
+	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 {
+	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
+}

crud/get.go

@@ -0,0 +1,84 @@
+package crud
+
+import (
+	"context"
+
+	"github.com/tarantool/go-tarantool"
+)
+
+type GetOpts struct {
+	Timeout       OptUint
+	VshardRouter  OptString
+	Fields        OptTuple
+	BucketId      OptUint
+	Mode          OptString
+	PreferReplica OptBool
+	Balance       OptBool
+}
+
+func (opts GetOpts) EncodeMsgpack(enc *encoder) error {
+	const optsCnt = 7
+
+	options := []option{opts.Timeout, opts.VshardRouter,
+		opts.Fields, opts.BucketId, opts.Mode,
+		opts.PreferReplica, opts.Balance}
+	names := []string{timeoutOptName, vshardRouterOptName,
+		fieldsOptName, bucketIdOptName, modeOptName,
+		preferReplicaOptName, balanceOptName}
+	values := make([]interface{}, optsCnt)
+
+	return encodeOptions(enc, options, names, values)
+}
+
+// GetRequest helps you to create request object to call `crud.get`
+// for execution by a Connection.
+type GetRequest struct {
+	spaceRequest
+	key  Tuple
+	opts GetOpts
+}
+
+type getArgs struct {
+	_msgpack struct{} `msgpack:",asArray"` //nolint: structcheck,unused
+	Space    string
+	Key      Tuple
+	Opts     GetOpts
+}
+
+// NewGetRequest returns a new empty GetRequest.
+func NewGetRequest(space string) *GetRequest {
+	req := new(GetRequest)
+	req.initImpl("crud.get")
+	req.setSpace(space)
+	req.key = Tuple{}
+	req.opts = GetOpts{}
+	return req
+}
+
+// Key sets the key for the GetRequest request.
+// Note: default value is nil.
+func (req *GetRequest) Key(key Tuple) *GetRequest {
+	req.key = key
+	return req
+}
+
+// Opts sets the options for the GetRequest request.
+// Note: default value is nil.
+func (req *GetRequest) Opts(opts GetOpts) *GetRequest {
+	req.opts = opts
+	return req
+}
+
+// Body fills an encoder with the call request body.
+func (req *GetRequest) Body(res tarantool.SchemaResolver, enc *encoder) error {
+	args := getArgs{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 *GetRequest) Context(ctx context.Context) *GetRequest {
+	req.impl = req.impl.Context(ctx)
+
+	return req
+}