api: add structures to describe CRUD response

Author: AnaNek

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,79 @@
+package crud
+
+import (
+	"fmt"
+)
+
+// CrudError describes CRUD error object.
+type CrudError 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
+}
+
+// NewCrudError creates new CRUD error.
+func NewCrudError(rawErr interface{}) (*CrudError, error) {
+	var (
+		mapErr map[interface{}]interface{}
+		ok     bool
+	)
+
+	crudErr := CrudError{}
+
+	if mapErr, ok = rawErr.(map[interface{}]interface{}); !ok {
+		return nil, fmt.Errorf("Unexpected CRUD error format: %#v", rawErr)
+	}
+
+	if value, ok := mapErr["class_name"]; ok {
+		if className, ok := value.(string); ok {
+			crudErr.ClassName = className
+		}
+	}
+
+	if value, ok := mapErr["err"]; ok {
+		if err, ok := value.(string); ok {
+			crudErr.Err = err
+		}
+	}
+
+	if value, ok := mapErr["file"]; ok {
+		if file, ok := value.(string); ok {
+			crudErr.File = file
+		}
+	}
+
+	if value, ok := mapErr["line"]; ok {
+		if line, ok := value.(uint64); ok {
+			crudErr.Line = line
+		}
+	}
+
+	if value, ok := mapErr["stack"]; ok {
+		if stack, ok := value.(string); ok {
+			crudErr.Stack = stack
+		}
+	}
+
+	if value, ok := mapErr["str"]; ok {
+		if str, ok := value.(string); ok {
+			crudErr.Str = str
+		}
+	}
+
+	return &crudErr, nil
+}
+
+// Error converts an CrudError to a string.
+func (err CrudError) Error() string {
+	return err.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 = Result
+
 // 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 = Result
+
+// 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 {