api: add structures to describe CRUD response

Author: AnaNek

Makefile

@@ -27,7 +27,7 @@ clean:
 .PHONY: deps
 deps: clean
 	( cd ./queue/testdata; $(TTCTL) rocks install queue 1.2.1 )
-	( cd ./crud/testdata; $(TTCTL) rocks install crud 0.14.1 )
+	( cd ./crud/testdata; $(TTCTL) rocks install crud 1.0.0 )
 
 .PHONY: datetime-timezones
 datetime-timezones:

crud/count.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// CountResult describes result for `crud.count` method.
+type CountResult = NumberResult
+
 // CountOpts describes options for `crud.count` method.
 type CountOpts struct {
 	// Timeout is a `vshard.call` timeout and vshard

crud/delete.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// DeleteResult describes result for `crud.delete` method.
+type DeleteResult = Result
+
 // DeleteOpts describes options for `crud.delete` method.
 type DeleteOpts = SimpleOperationOpts
 

crud/error.go

@@ -0,0 +1,84 @@
+package crud
+
+// Error describes CRUD error object.
+type Error struct {
+	// ClassName is an error class that implies its source (for example, "CountError").
+	ClassName string
+	// Err is the text of reason.
+	Err string
+	// File is a source code file where the error was caught.
+	File string
+	// Line is a number of line in the source code file where the error was caught.
+	Line uint64
+	// Stack is an information about the call stack when an error
+	// occurs in a string format.
+	Stack string
+	// Str is the text of reason with error class.
+	Str string
+}
+
+// DecodeMsgpack provides custom msgpack decoder.
+func (crudErr *Error) DecodeMsgpack(d *decoder) error {
+	l, err := d.DecodeMapLen()
+	if err != nil {
+		return err
+	}
+	for i := 0; i < l; i++ {
+		key, err := d.DecodeString()
+		if err != nil {
+			return err
+		}
+		switch key {
+		case "class_name":
+			if crudErr.ClassName, err = d.DecodeString(); err != nil {
+				return err
+			}
+		case "err":
+			if crudErr.Err, err = d.DecodeString(); err != nil {
+				return err
+			}
+		case "file":
+			if crudErr.File, err = d.DecodeString(); err != nil {
+				return err
+			}
+		case "line":
+			if crudErr.Line, err = d.DecodeUint64(); err != nil {
+				return err
+			}
+		case "stack":
+			if crudErr.Stack, err = d.DecodeString(); err != nil {
+				return err
+			}
+		case "str":
+			if crudErr.Str, err = d.DecodeString(); err != nil {
+				return err
+			}
+		default:
+			if err := d.Skip(); err != nil {
+				return err
+			}
+		}
+	}
+
+	return nil
+}
+
+// Error converts an Error to a string.
+func (err Error) Error() string {
+	return err.Str
+}
+
+// ErrorMany describes CRUD error object for `_many` methods.
+type ErrorMany struct {
+	Errors []Error
+}
+
+// Error converts an Error to a string.
+func (errs ErrorMany) Error() string {
+	str := ""
+	for _, err := range errs.Errors {
+		str += err.Str
+	}
+
+	return str
+}

crud/get.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// GetResult describes result for `crud.get` method.
+type GetResult = Result
+
 // GetOpts describes options for `crud.get` method.
 type GetOpts struct {
 	// Timeout is a `vshard.call` timeout and vshard

crud/insert.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// InsertResult describes result for `crud.insert` method.
+type InsertResult = Result
+
 // InsertOpts describes options for `crud.insert` method.
 type InsertOpts = SimpleOperationOpts
 
@@ -62,6 +65,9 @@ func (req *InsertRequest) Context(ctx context.Context) *InsertRequest {
 	return req
 }
 
+// InsertObjectResult describes result for `crud.insert_object` method.
+type InsertObjectResult = Result
+
 // InsertObjectOpts describes options for `crud.insert_object` method.
 type InsertObjectOpts = SimpleOperationObjectOpts
 

crud/insert_many.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// InsertManyResult describes result for `crud.insert_many` method.
+type InsertManyResult = ResultMany
+
 // InsertManyOpts describes options for `crud.insert_many` method.
 type InsertManyOpts = OperationManyOpts
 
@@ -62,7 +65,10 @@ func (req *InsertManyRequest) Context(ctx context.Context) *InsertManyRequest {
 	return req
 }
 
-// InsertManyOpts describes options for `crud.insert_object_many` method.
+// InsertObjectManyResult describes result for `crud.insert_object_many` method.
+type InsertObjectManyResult = ResultMany
+
+// InsertObjectManyOpts describes options for `crud.insert_object_many` method.
 type InsertObjectManyOpts = OperationObjectManyOpts
 
 // InsertObjectManyRequest helps you to create request object to call

crud/len.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// LenResult describes result for `crud.len` method.
+type LenResult = NumberResult
+
 // LenOpts describes options for `crud.len` method.
 type LenOpts = BaseOpts
 

crud/max.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// MaxResult describes result for `crud.max` method.
+type MaxResult = Result
+
 // MaxOpts describes options for `crud.max` method.
 type MaxOpts = BorderOpts
 

crud/min.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// MinResult describes result for `crud.min` method.
+type MinResult = Result
+
 // MinOpts describes options for `crud.min` method.
 type MinOpts = BorderOpts
 

crud/msgpack.go

@@ -10,6 +10,7 @@ import (
 )
 
 type encoder = msgpack.Encoder
+type decoder = msgpack.Decoder
 
 // Object is an interface to describe object for CRUD methods.
 type Object interface {

crud/msgpack_v5.go

@@ -10,6 +10,7 @@ import (
 )
 
 type encoder = msgpack.Encoder
+type decoder = msgpack.Decoder
 
 // Object is an interface to describe object for CRUD methods.
 type Object interface {

crud/replace.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// ReplaceResult describes result for `crud.replace` method.
+type ReplaceResult = Result
+
 // ReplaceOpts describes options for `crud.replace` method.
 type ReplaceOpts = SimpleOperationOpts
 
@@ -62,6 +65,9 @@ func (req *ReplaceRequest) Context(ctx context.Context) *ReplaceRequest {
 	return req
 }
 
+// ReplaceObjectResult describes result for `crud.replace_object` method.
+type ReplaceObjectResult = Result
+
 // ReplaceObjectOpts describes options for `crud.replace_object` method.
 type ReplaceObjectOpts = SimpleOperationObjectOpts
 

crud/replace_many.go

@@ -6,6 +6,9 @@ import (
 	"github.com/tarantool/go-tarantool"
 )
 
+// ReplaceManyResult describes result for `crud.replace_many` method.
+type ReplaceManyResult = ResultMany
+
 // ReplaceManyOpts describes options for `crud.replace_many` method.
 type ReplaceManyOpts = OperationManyOpts
 
@@ -62,6 +65,9 @@ func (req *ReplaceManyRequest) Context(ctx context.Context) *ReplaceManyRequest
 	return req
 }
 
+// ReplaceObjectManyResult describes result for `crud.replace_object_many` method.
+type ReplaceObjectManyResult = ResultMany
+
 // ReplaceObjectManyOpts describes options for `crud.replace_object_many` method.
 type ReplaceObjectManyOpts = OperationObjectManyOpts