Test

Author: viciious

defaults.go

@@ -4,13 +4,14 @@ import "time"
 
 const (
 	DefaultIndex = "primary"
-	DefaultLimit = 250
 
 	DefaultConnectTimeout = time.Second
 	DefaultQueryTimeout   = time.Second
 )
 
 var (
+	DefaultLimit = 250
+
 	DefaultReaderBufSize = 16 * 1024
 	DefaultWriterBufSize = 4 * 1024
 

pack_data.go

@@ -13,7 +13,6 @@ type packData struct {
 	packedDefaultSpace  []byte
 	packedDefaultIndex  []byte
 	packedIterEq        []byte
-	packedDefaultLimit  []byte
 	packedDefaultOffset []byte
 	packedSingleKey     []byte
 	spaceMap            map[string]uint64
@@ -52,7 +51,6 @@ func newPackData(defaultSpace interface{}) *packData {
 		packedDefaultSpace:  packedDefaultSpace,
 		packedDefaultIndex:  encodeValues2(KeyIndexNo, uint32(0)),
 		packedIterEq:        encodeValues2(KeyIterator, IterEq),
-		packedDefaultLimit:  encodeValues2(KeyLimit, DefaultLimit),
 		packedDefaultOffset: encodeValues2(KeyOffset, 0),
 		packedSingleKey:     packSelectSingleKey(),
 		spaceMap:            make(map[string]uint64),

select.go

@@ -42,7 +42,8 @@ func (q *Select) packMsg(data *packData, b []byte) (o []byte, err error) {
 	}
 
 	if q.Limit == 0 {
-		o = append(o, data.packedDefaultLimit...)
+		o = msgp.AppendUint(o, KeyLimit)
+		o = msgp.AppendUint(o, uint(DefaultLimit))
 	} else {
 		o = msgp.AppendUint(o, KeyLimit)
 		o = msgp.AppendUint(o, uint(q.Limit))