crud: support schema opts

Follows #336

Author: DifferentialOrange

CHANGELOG.md

@@ -23,6 +23,7 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release.
 - Support `IPROTO_WATCH_ONCE` request type for Tarantool 
   version >= 3.0.0-alpha1 (#337)
 - Support `yield_every` option for crud select requests (#350)
+- Support `crud.schema` request options (#351)
 
 ### Changed
 

crud/options.go

@@ -23,6 +23,7 @@ const (
 	batchSizeOptName                     = "batch_size"
 	fetchLatestMetadataOptName           = "fetch_latest_metadata"
 	noreturnOptName                      = "noreturn"
+	cachedOptName                        = "cached"
 )
 
 // OptUint is an optional uint.

crud/schema.go

@@ -14,11 +14,39 @@ func msgpackIsMap(code byte) bool {
 	return code == msgpcode.Map16 || code == msgpcode.Map32 || msgpcode.IsFixedMap(code)
 }
 
+// SchemaOpts describes options for `crud.schema` method.
+type SchemaOpts struct {
+	// Timeout is a `vshard.call` timeout and vshard
+	// master discovery timeout (in seconds).
+	Timeout OptFloat64
+	// VshardRouter is cartridge vshard group name or
+	// vshard router instance.
+	VshardRouter OptString
+	// Cached defines whether router should reload storage schema on call.
+	Cached OptBool
+}
+
+// EncodeMsgpack provides custom msgpack encoder.
+func (opts SchemaOpts) EncodeMsgpack(enc *msgpack.Encoder) error {
+	const optsCnt = 3
+
+	names := [optsCnt]string{timeoutOptName, vshardRouterOptName,
+		cachedOptName}
+	values := [optsCnt]interface{}{}
+	exists := [optsCnt]bool{}
+	values[0], exists[0] = opts.Timeout.Get()
+	values[1], exists[1] = opts.VshardRouter.Get()
+	values[2], exists[2] = opts.Cached.Get()
+
+	return encodeOptions(enc, names[:], values[:], exists[:])
+}
+
 // SchemaRequest helps you to create request object to call `crud.schema`
 // for execution by a Connection.
 type SchemaRequest struct {
 	baseRequest
 	space OptString
+	opts  SchemaOpts
 }
 
 // MakeSchemaRequest returns a new empty SchemaRequest.
@@ -35,6 +63,13 @@ func (req SchemaRequest) Space(space string) SchemaRequest {
 	return req
 }
 
+// Opts sets the options for the SelectRequest request.
+// Note: default value is nil.
+func (req SchemaRequest) Opts(opts SchemaOpts) SchemaRequest {
+	req.opts = opts
+	return req
+}
+
 // Body fills an encoder with the call request body.
 func (req SchemaRequest) Body(res tarantool.SchemaResolver, enc *msgpack.Encoder) error {
 	if value, ok := req.space.Get(); ok {

crud/tarantool_test.go

@@ -87,6 +87,11 @@ var opObjManyOpts = crud.OperationObjectManyOpts{
 	Timeout: crud.MakeOptFloat64(timeout),
 }
 
+var schemaOpts = crud.SchemaOpts{
+	Timeout: crud.MakeOptFloat64(timeout),
+	Cached:  crud.MakeOptBool(false),
+}
+
 var conditions = []crud.Condition{
 	{
 		Operator: crud.Lt,
@@ -216,6 +221,11 @@ var testProcessDataCases = []struct {
 		1,
 		crud.MakeStorageInfoRequest().Opts(baseOpts),
 	},
+	{
+		"Schema",
+		1,
+		crud.MakeSchemaRequest().Opts(schemaOpts),
+	},
 }
 
 var testResultWithErrCases = []struct {