cdt_list_test.go

// Copyright 2014-2022 Aerospike, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package aerospike_test

import (
	"errors"
	"math"

	gg "github.com/onsi/ginkgo/v2"
	gm "github.com/onsi/gomega"

	as "github.com/aerospike/aerospike-client-go/v7"
)

var _ = gg.Describe("CDT List Test", func() {

	// connection data
	var ns = *namespace
	var set = randString(50)
	var key *as.Key
	var wpolicy = as.NewWritePolicy(0, 0)
	var cdtBinName string
	var list []interface{}

	gg.BeforeEach(func() {

		if !featureEnabled("cdt-list") {
			gg.Skip("CDT List Tests will not run since feature is not supported by the server.")
			return
		}

		key, err = as.NewKey(ns, set, randString(50))
		gm.Expect(err).ToNot(gm.HaveOccurred())

		cdtBinName = randString(10)
	})

	gg.It("should create a valid CDT List", func() {
		cdtList, err := client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, 0))
		gm.Expect(errors.Is(err, as.ErrKeyNotFound)).To(gm.BeTrue())
		gm.Expect(cdtList).To(gm.BeNil())

		list := []interface{}{}
		for i := 1; i <= 100; i++ {
			list = append(list, i)

			sz, err := client.Operate(wpolicy, key, as.ListAppendOp(cdtBinName, i))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(sz.Bins[cdtBinName]).To(gm.Equal(i))

			sz, err = client.Operate(wpolicy, key, as.ListSizeOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(sz.Bins[cdtBinName]).To(gm.Equal(i))
		}

		sz, err := client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, 100))
		gm.Expect(err).ToNot(gm.HaveOccurred())
		gm.Expect(sz.Bins[cdtBinName]).To(gm.Equal(list))

		sz, err = client.Operate(wpolicy, key, as.ListAppendOp(cdtBinName, list...))
		gm.Expect(err).ToNot(gm.HaveOccurred())
		gm.Expect(sz.Bins[cdtBinName]).To(gm.Equal(100 * 2))
	})

	gg.It("should create a valid CDT List with persisted index", func() {
		cdtBinName := "indexedList"
		cdtList, err := client.Operate(wpolicy, key,
			as.ListCreateWithIndexOp(cdtBinName, as.ListOrderOrdered, false),
			as.ListAppendWithPolicyOp(as.DefaultListPolicy(), cdtBinName, 1, 2, 3, 4),
			as.GetBinOp(cdtBinName),
		)
		gm.Expect(err).ToNot(gm.HaveOccurred())
		gm.Expect(cdtList).ToNot(gm.BeNil())
		gm.Expect(cdtList.Bins).ToNot(gm.BeNil())
		gm.Expect(cdtList.Bins[cdtBinName]).To(gm.Equal([]interface{}{4, []interface{}{1, 2, 3, 4}}))
	})

	gg.Describe("CDT List Operations", func() {

		const listSize = 10

		// make a fresh list before each operation
		gg.BeforeEach(func() {
			_, err = client.Delete(nil, key)
			gm.Expect(err).ToNot(gm.HaveOccurred())

			list = []interface{}{}

			for i := 1; i <= listSize; i++ {
				list = append(list, i)

				sz, err := client.Operate(wpolicy, key, as.ListAppendOp(cdtBinName, i))
				gm.Expect(err).ToNot(gm.HaveOccurred())
				gm.Expect(sz.Bins[cdtBinName]).To(gm.Equal(i))
			}
		})

		gg.It("should Get the last element", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize))
		})

		gg.It("should Get the last element again", func() {
			ops := []*as.Operation{as.ListGetOp(cdtBinName, -1)}
			cdtListRes, err := client.Operate(wpolicy, key, ops...)
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize))

			cdtListRes, err = client.Operate(wpolicy, key, ops...)
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize))
		})

		gg.It("should Get the last 3 element", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, -3, 3))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{listSize - 2, listSize - 1, listSize - 0}))
		})

		gg.It("should Get the from element #7 till the end of list", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 7))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{listSize - 2, listSize - 1, listSize - 0}))
		})

		gg.It("should Get by value", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetByValueOp(cdtBinName, 7, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{7}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByValueListOp(cdtBinName, []interface{}{7, 9}, as.ListReturnTypeIndex))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{6, 8}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByValueRangeOp(cdtBinName, 5, 9, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{5, 6, 7, 8}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByValueRangeOp(cdtBinName, 5, 9, as.ListReturnTypeIndex))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{4, 5, 6, 7}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByValueRangeOp(cdtBinName, 5, 9, as.ListReturnTypeExists))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(true))
		})

		gg.It("should Get by index", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetByIndexOp(cdtBinName, 7, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(8))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByIndexRangeOp(cdtBinName, 7, as.ListReturnTypeIndex))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{7, 8, 9}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByIndexRangeOp(cdtBinName, 7, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{8, 9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByIndexRangeOp(cdtBinName, 8, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByIndexRangeCountOp(cdtBinName, 5, 2, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{6, 7}))
		})

		gg.It("should Get by rank", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetByRankOp(cdtBinName, 7, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(8))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByRankRangeOp(cdtBinName, 7, as.ListReturnTypeIndex))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{7, 8, 9}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByRankRangeOp(cdtBinName, 7, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{8, 9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByRankRangeOp(cdtBinName, 8, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetByRankRangeCountOp(cdtBinName, 5, 2, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{6, 7}))
		})

		gg.It("should append an element to the tail", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListAppendOp(cdtBinName, math.MaxInt64))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 1))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, listSize))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(math.MaxInt64))
		})

		gg.It("should append the same cached element to the tail", func() {
			ops := []*as.Operation{as.ListAppendOp(cdtBinName, math.MaxInt64)}
			cdtListRes, err := client.Operate(wpolicy, key, ops...)
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 1))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, listSize))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(math.MaxInt64))

			cdtListRes, err = client.Operate(wpolicy, key, ops...)
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 2))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, listSize))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(math.MaxInt64))
		})

		gg.It("should append a few elements to the tail", func() {
			elems := []interface{}{math.MaxInt64, math.MaxInt64 - 1, math.MaxInt64 - 2}
			cdtListRes, err := client.Operate(wpolicy, key, as.ListAppendOp(cdtBinName, elems...))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, listSize, 3))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(elems))
		})

		gg.It("should append a few elements to the tail with policy", func() {
			elems := []interface{}{math.MaxInt64, math.MaxInt64 - 1, math.MaxInt64 - 2}
			cdtListRes, err := client.Operate(wpolicy, key, as.ListAppendWithPolicyOp(as.DefaultListPolicy(), cdtBinName, elems...))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListAppendWithPolicyOp(as.DefaultListPolicy(), cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 4))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, listSize, 4))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			elems = append(elems, 0)
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(elems))
		})

		gg.It("should prepend an element to the head via ListInsertOp", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListInsertOp(cdtBinName, 0, math.MaxInt64))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 1))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(math.MaxInt64))
		})

		gg.It("should prepend an element to the head via ListInsertWithPolicyOp", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListInsertWithPolicyOp(as.DefaultListPolicy(), cdtBinName, 0, math.MaxInt64))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 1))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListInsertWithPolicyOp(as.DefaultListPolicy(), cdtBinName, 0, math.MaxInt64-1, math.MaxInt64-2))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{math.MaxInt64 - 1, math.MaxInt64 - 2, math.MaxInt64, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10}))
		})

		gg.It("should prepend a few elements to the tail via ListInsertOp", func() {
			elems := []interface{}{math.MaxInt64, math.MaxInt64 - 1, math.MaxInt64 - 2}
			cdtListRes, err := client.Operate(wpolicy, key, as.ListInsertOp(cdtBinName, 0, elems...))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(listSize + 3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, 3))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(elems))
		})

		gg.It("should pop elements from the head", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListPopRangeOp(cdtBinName, 0, 3))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list[:3]))

			cdtListRes, err = client.Operate(wpolicy, key, as.GetBinOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list[3:]))
		})

		gg.It("should pop element range from the index", func() {
			for i := listSize; i > 0; i-- {
				cdtListRes, err := client.Operate(wpolicy, key, as.ListPopOp(cdtBinName, 0))
				gm.Expect(err).ToNot(gm.HaveOccurred())
				gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list[0]))

				list = list[1:]

				// TODO: Remove the IF later when server has changed
				if i > 1 {
					cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, i))
					gm.Expect(err).ToNot(gm.HaveOccurred())
					gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list))
				}
			}
		})

		gg.It("should pop elements from element #7 to the end of list", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list))

			cdtPopRes, err := client.Operate(wpolicy, key, as.ListPopRangeFromOp(cdtBinName, 7))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtPopRes.Bins[cdtBinName]).To(gm.Equal(list[7:]))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list[:7]))

		})

		gg.It("should remove elements from the head", func() {
			for i := listSize; i > 0; i-- {
				cdtListRes, err := client.Operate(wpolicy, key, as.ListRemoveOp(cdtBinName, 0))
				gm.Expect(err).ToNot(gm.HaveOccurred())
				gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(1))

				list = list[1:]

				// TODO: Remove the IF later when server has changed
				if i > 1 {
					cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, i))
					gm.Expect(err).ToNot(gm.HaveOccurred())
					gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list))
				}
			}
		})

		gg.It("should remove elements from element #7 to the end of list", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list))

			cdtRemoveRes, err := client.Operate(wpolicy, key, as.ListRemoveRangeFromOp(cdtBinName, 7))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtRemoveRes.Bins[cdtBinName]).To(gm.Equal(3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list[:7]))

		})

		gg.It("should remove elements from the head in increasing numbers", func() {
			elemCount := listSize
			for i := 1; i <= 4; i++ {
				cdtListRes, err := client.Operate(wpolicy, key, as.ListRemoveRangeOp(cdtBinName, 0, i))
				gm.Expect(err).ToNot(gm.HaveOccurred())
				gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(i))

				list = list[i:]
				elemCount -= i

				// TODO: Remove the IF later when server has changed
				cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, elemCount))
				if elemCount > 0 {
					gm.Expect(err).ToNot(gm.HaveOccurred())
					gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list))
				}
			}
		})

		gg.It("should remove elements by value", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListRemoveByValueListOp(cdtBinName, []interface{}{1, 2, 3, 4, 5, 6, 7}, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{1, 2, 3, 4, 5, 6, 7}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{8, 9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListRemoveByValueOp(cdtBinName, 9, as.ListReturnTypeCount))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(1))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{8, 10}))
		})

		gg.It("should remove elements by value range", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListRemoveByValueRangeOp(cdtBinName, as.ListReturnTypeValue, 1, 5))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{1, 2, 3, 4}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{5, 6, 7, 8, 9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListRemoveByValueRangeOp(cdtBinName, as.ListReturnTypeCount, 6, 9))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{5, 9, 10}))
		})

		gg.It("should remove elements by index", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListRemoveByIndexOp(cdtBinName, 0, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(1))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{2, 3, 4, 5, 6, 7, 8, 9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListRemoveByIndexRangeOp(cdtBinName, 5, as.ListReturnTypeCount))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(4))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{2, 3, 4, 5, 6}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListRemoveByIndexRangeCountOp(cdtBinName, 2, 3, as.ListReturnTypeCount))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{2, 3}))
		})

		gg.It("should remove elements by rank", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListSortOp(cdtBinName, as.ListSortFlagsDefault))
			gm.Expect(err).ToNot(gm.HaveOccurred())

			cdtListRes, err = client.Operate(wpolicy, key, as.ListRemoveByRankOp(cdtBinName, 0, as.ListReturnTypeValue))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(1))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{2, 3, 4, 5, 6, 7, 8, 9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListRemoveByRankRangeOp(cdtBinName, 5, as.ListReturnTypeCount))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(4))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{2, 3, 4, 5, 6}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListRemoveByRankRangeCountOp(cdtBinName, 2, 3, as.ListReturnTypeCount))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{2, 3}))
		})

		gg.It("should increment elements", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list))

			elemRes, err := client.Operate(wpolicy, key, as.ListIncrementOp(cdtBinName, 0, 10))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(11))

			elemRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(11))

			elemRes, err = client.Operate(wpolicy, key, as.ListIncrementByOneOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(12))

			elemRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(12))
		})

		gg.It("should increment elements with policy", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(list))

			elemRes, err := client.Operate(wpolicy, key, as.ListIncrementWithPolicyOp(as.DefaultListPolicy(), cdtBinName, 0, 10))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(11))

			elemRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(11))

			elemRes, err = client.Operate(wpolicy, key, as.ListIncrementByOneWithPolicyOp(as.DefaultListPolicy(), cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(12))

			elemRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(12))
		})

		gg.It("should sort elements with policy", func() {
			elemRes, err := client.Operate(wpolicy, key, as.ListIncrementWithPolicyOp(as.DefaultListPolicy(), cdtBinName, 0, 100))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(elemRes.Bins[cdtBinName]).To(gm.Equal(101))

			cdtListRes, err := client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{101, 2, 3, 4, 5, 6, 7, 8, 9, 10}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListSortOp(cdtBinName, as.ListSortFlagsDefault))
			gm.Expect(err).ToNot(gm.HaveOccurred())

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeFromOp(cdtBinName, 0))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal([]interface{}{2, 3, 4, 5, 6, 7, 8, 9, 10, 101}))
		})

		gg.It("should set elements", func() {
			elems := []interface{}{}
			for i := 0; i < listSize; i++ {
				cdtListRes, err := client.Operate(wpolicy, key, as.ListSetOp(cdtBinName, i, math.MaxInt64))
				gm.Expect(err).ToNot(gm.HaveOccurred())
				gm.Expect(cdtListRes.Bins).To(gm.Equal(as.BinMap{}))

				elems = append(elems, math.MaxInt64)

				cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, i+1))
				gm.Expect(err).ToNot(gm.HaveOccurred())
				gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(elems))
			}
		})

		gg.It("should set the last element", func() {
			cdtListRes, err := client.Operate(wpolicy, key, as.ListSetOp(cdtBinName, -1, math.MaxInt64))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins).To(gm.Equal(as.BinMap{}))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetOp(cdtBinName, -1))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(math.MaxInt64))
		})

		gg.It("should trim list elements", func() {
			elems := []interface{}{3, 4, 5}
			cdtListRes, err := client.Operate(wpolicy, key, as.ListTrimOp(cdtBinName, 2, 3))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(7))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListSizeOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(3))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListGetRangeOp(cdtBinName, 0, 3))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(elems))
		})

		gg.It("should clear list elements", func() {
			for i := 0; i < listSize; i++ {
				_, err := client.Operate(wpolicy, key, as.ListAppendOp(cdtBinName, i))
				gm.Expect(err).ToNot(gm.HaveOccurred())
			}
			cdtListRes, err := client.Operate(wpolicy, key, as.ListSizeOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).NotTo(gm.Equal(0))

			cdtListRes, err = client.Operate(wpolicy, key, as.ListClearOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.BeNil())

			cdtListRes, err = client.Operate(wpolicy, key, as.ListSizeOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(cdtListRes.Bins[cdtBinName]).To(gm.Equal(0))
		})

		gg.It("should support ListWriteFlagsPartial & ListWriteFlagsNoFail", func() {
			client.Delete(nil, key)

			cdtBinName2 := cdtBinName + "2"

			list := []interface{}{0, 4, 5, 9, 9, 11, 15, 0}

			cdtListPolicy1 := as.NewListPolicy(as.ListOrderOrdered, as.ListWriteFlagsAddUnique|as.ListWriteFlagsPartial|as.ListWriteFlagsNoFail)
			cdtListPolicy2 := as.NewListPolicy(as.ListOrderOrdered, as.ListWriteFlagsAddUnique|as.ListWriteFlagsNoFail)
			record, err := client.Operate(wpolicy, key,
				as.ListAppendWithPolicyOp(cdtListPolicy1, cdtBinName, list...),
				as.ListAppendWithPolicyOp(cdtListPolicy2, cdtBinName2, list...),
			)
			gm.Expect(err).ToNot(gm.HaveOccurred())

			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal(6))
			gm.Expect(record.Bins[cdtBinName2]).To(gm.Equal(0))

			list = []interface{}{11, 3}

			record, err = client.Operate(wpolicy, key,
				as.ListAppendWithPolicyOp(cdtListPolicy1, cdtBinName, list...),
				as.ListAppendWithPolicyOp(cdtListPolicy2, cdtBinName2, list...),
			)
			gm.Expect(err).ToNot(gm.HaveOccurred())

			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal(7))
			gm.Expect(record.Bins[cdtBinName2]).To(gm.Equal(2))

		})

		gg.It("should support Relative GetList Ops", func() {
			client.Delete(nil, key)

			list := []interface{}{0, 4, 5, 9, 11, 15}

			cdtListPolicy := as.NewListPolicy(as.ListOrderOrdered, as.ListWriteFlagsDefault)
			record, err := client.Operate(wpolicy, key,
				as.ListAppendWithPolicyOp(cdtListPolicy, cdtBinName, list...),
				as.ListGetByValueRelativeRankRangeOp(cdtBinName, 5, 0, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeOp(cdtBinName, 5, 1, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeOp(cdtBinName, 5, -1, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeOp(cdtBinName, 3, 0, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeOp(cdtBinName, 3, 3, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeOp(cdtBinName, 3, -3, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeCountOp(cdtBinName, 5, 0, 2, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeCountOp(cdtBinName, 5, 1, 1, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeCountOp(cdtBinName, 5, -1, 2, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeCountOp(cdtBinName, 3, 0, 1, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeCountOp(cdtBinName, 3, 3, 7, as.ListReturnTypeValue),
				as.ListGetByValueRelativeRankRangeCountOp(cdtBinName, 3, -3, 2, as.ListReturnTypeValue),
			)
			gm.Expect(err).ToNot(gm.HaveOccurred())

			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal([]interface{}{6, []interface{}{5, 9, 11, 15}, []interface{}{9, 11, 15}, []interface{}{4, 5, 9, 11, 15}, []interface{}{4, 5, 9, 11, 15}, []interface{}{11, 15}, []interface{}{0, 4, 5, 9, 11, 15}, []interface{}{5, 9}, []interface{}{9}, []interface{}{4, 5}, []interface{}{4}, []interface{}{11, 15}, []interface{}{}}))
		})

		gg.It("should support Relative RemoveList Ops", func() {
			client.Delete(nil, key)

			list := []interface{}{0, 4, 5, 9, 11, 15}

			cdtListPolicy := as.NewListPolicy(as.ListOrderOrdered, as.ListWriteFlagsDefault)
			record, err := client.Operate(wpolicy, key,
				as.ListAppendWithPolicyOp(cdtListPolicy, cdtBinName, list...),
				as.ListRemoveByValueRelativeRankRangeOp(cdtBinName, as.ListReturnTypeValue, 5, 0),
				as.ListRemoveByValueRelativeRankRangeOp(cdtBinName, as.ListReturnTypeValue, 5, 1),
				as.ListRemoveByValueRelativeRankRangeOp(cdtBinName, as.ListReturnTypeValue, 5, -1),
				as.ListRemoveByValueRelativeRankRangeCountOp(cdtBinName, as.ListReturnTypeValue, 3, -3, 1),
				as.ListRemoveByValueRelativeRankRangeCountOp(cdtBinName, as.ListReturnTypeValue, 3, -3, 2),
				as.ListRemoveByValueRelativeRankRangeCountOp(cdtBinName, as.ListReturnTypeValue, 3, -3, 3),
			)
			gm.Expect(err).ToNot(gm.HaveOccurred())

			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal([]interface{}{6, []interface{}{5, 9, 11, 15}, []interface{}{}, []interface{}{4}, []interface{}{}, []interface{}{}, []interface{}{0}}))
		})

		gg.It("should support List Infinity Ops", func() {
			client.Delete(nil, key)

			list := []interface{}{0, 4, 5, 9, 11, 15}

			cdtListPolicy := as.NewListPolicy(as.ListOrderOrdered, as.ListWriteFlagsDefault)
			record, err := client.Operate(wpolicy, key,
				as.ListAppendWithPolicyOp(cdtListPolicy, cdtBinName, list...),
				as.ListGetByValueRangeOp(cdtBinName, 10, as.NewInfinityValue(), as.ListReturnTypeValue),
			)
			gm.Expect(err).ToNot(gm.HaveOccurred())

			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal([]interface{}{6, []interface{}{11, 15}}))
		})

		gg.It("should support List WildCard Ops", func() {
			client.Delete(nil, key)

			list := []interface{}{
				[]interface{}{"John", 55},
				[]interface{}{"Jim", 95},
				[]interface{}{"Joe", 80},
			}

			cdtListPolicy := as.NewListPolicy(as.ListOrderOrdered, as.ListWriteFlagsDefault)
			record, err := client.Operate(wpolicy, key,
				as.ListAppendWithPolicyOp(cdtListPolicy, cdtBinName, list...),
				as.ListGetByValueOp(cdtBinName, []interface{}{"Jim", as.NewWildCardValue()}, as.ListReturnTypeValue),
			)
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal([]interface{}{3, []interface{}{[]interface{}{"Jim", 95}}}))
		})

		gg.It("should support Nested List Ops", func() {
			client.Delete(nil, key)

			list := []interface{}{
				[]interface{}{7, 9, 5},
				[]interface{}{1, 2, 3},
				[]interface{}{6, 5, 4, 1},
			}

			err := client.Put(wpolicy, key, as.BinMap{cdtBinName: list})
			gm.Expect(err).ToNot(gm.HaveOccurred())

			record, err := client.Operate(wpolicy, key, as.GetBinOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal(list))

			record, err = client.Operate(wpolicy, key, as.ListAppendWithPolicyContextOp(as.DefaultListPolicy(), cdtBinName, []*as.CDTContext{as.CtxListIndex(-1)}, 11), as.GetBinOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())

			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal([]interface{}{
				5,
				[]interface{}{
					[]interface{}{7, 9, 5},
					[]interface{}{1, 2, 3},
					[]interface{}{6, 5, 4, 1, 11},
				},
			}))
		})

		gg.It("should support Nested List Map Ops", func() {
			client.Delete(nil, key)

			m := map[interface{}]interface{}{
				"key1": []interface{}{
					[]interface{}{7, 9, 5},
					[]interface{}{13},
				},
				"key2": []interface{}{
					[]interface{}{9},
					[]interface{}{2, 4},
					[]interface{}{6, 1, 9},
				},
			}

			err := client.Put(wpolicy, key, as.BinMap{cdtBinName: m})
			gm.Expect(err).ToNot(gm.HaveOccurred())

			record, err := client.Operate(wpolicy, key, as.GetBinOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())
			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal(m))

			record, err = client.Operate(wpolicy, key, as.ListAppendWithPolicyContextOp(as.DefaultListPolicy(), cdtBinName, []*as.CDTContext{as.CtxMapKey(as.StringValue("key2")), as.CtxListRank(0)}, 11), as.GetBinOp(cdtBinName))
			gm.Expect(err).ToNot(gm.HaveOccurred())

			gm.Expect(record.Bins[cdtBinName]).To(gm.Equal([]interface{}{
				3,
				map[interface{}]interface{}{
					"key1": []interface{}{
						[]interface{}{7, 9, 5},
						[]interface{}{13},
					},
					"key2": []interface{}{
						[]interface{}{9},
						[]interface{}{2, 4, 11},
						[]interface{}{6, 1, 9},
					},
				}}))
		})

		gg.It("should support Create List Ops", func() {
			client.Delete(nil, key)

			l1 := []as.Value{as.IntegerValue(7), as.IntegerValue(9), as.IntegerValue(5)}
			l2 := []as.Value{as.IntegerValue(1), as.IntegerValue(2), as.IntegerValue(3)}
			l3 := []as.Value{as.IntegerValue(6), as.IntegerValue(5), as.IntegerValue(4), as.IntegerValue(1)}
			inputList := []interface{}{as.ValueArray(l1), as.ValueArray(l2), as.ValueArray(l3)}

			// Create list.
			record, err := client.Operate(nil, key,
				as.ListAppendWithPolicyOp(as.NewListPolicy(as.ListOrderOrdered, 0), cdtBinName, inputList...),
				as.GetBinOp(cdtBinName),
			)
			gm.Expect(err).ToNot(gm.HaveOccurred())

			// Append value to new list created after the original 3 lists.
			record, err = client.Operate(nil, key,
				as.ListAppendWithPolicyContextOp(as.NewListPolicy(as.ListOrderOrdered, 0), cdtBinName, []*as.CDTContext{as.CtxListIndexCreate(3, as.ListOrderOrdered, false)}, as.IntegerValue(2)),
				as.GetBinOp(cdtBinName),
			)
			gm.Expect(err).ToNot(gm.HaveOccurred())

			results := record.Bins[cdtBinName].([]interface{})

			count := results[0]
			gm.Expect(count).To(gm.Equal(1))

			list := results[1].([]interface{})
			gm.Expect(len(list)).To(gm.Equal(4))

			// Test last nested list.
			list = list[1].([]interface{})
			gm.Expect(len(list)).To(gm.Equal(1))
			gm.Expect(list[0]).To(gm.Equal(2))
		})

	})

}) // describe