kvtest

Documentation

Index

• Constants
• Variables
• func DriverTest(t *testing.T, ms MakeStore)
• func GetStore(ctx context.Context, t testing.TB) kv.Store
• type MakeStore
• type StoreWithCounter
  • func NewStoreWithCounter(store kv.Store) *StoreWithCounter
  • func (swc *StoreWithCounter) Scan(ctx context.Context, partitionKey []byte, options kv.ScanOptions) (kv.EntriesIterator, error)
• type TestModel
  • func (*TestModel) Descriptor() ([]byte, []int)
  • func (x *TestModel) GetADouble() float64
  • func (x *TestModel) GetJustAString() string
  • func (x *TestModel) GetName() []byte
  • func (x *TestModel) GetTestList() []bool
  • func (x *TestModel) GetTestMap() map[string]int32
  • func (x *TestModel) GetTestTime() *timestamppb.Timestamp
  • func (*TestModel) ProtoMessage()
  • func (x *TestModel) ProtoReflect() protoreflect.Message
  • func (x *TestModel) Reset()
  • func (x *TestModel) String() string

Constants

const MaxPageSize = 10

MaxPageSize is the maximum page size for pagination tests

Variables

var File_kv_kvtest_test_model_proto protoreflect.FileDescriptor

Functions

func DriverTest

func DriverTest(t *testing.T, ms MakeStore)

func GetStore

func GetStore(ctx context.Context, t testing.TB) kv.Store

GetStore helper function to return Store object for all unit tests

Types

type MakeStore

type MakeStore func(t testing.TB, ctx context.Context) kv.Store

type StoreWithCounter

type StoreWithCounter struct {
	kv.Store
	ScanCalls int64
}

func NewStoreWithCounter

func NewStoreWithCounter(store kv.Store) *StoreWithCounter

func (*StoreWithCounter) Scan

func (swc *StoreWithCounter) Scan(ctx context.Context, partitionKey []byte, options kv.ScanOptions) (kv.EntriesIterator, error)

type TestModel

type TestModel struct {
	Name        []byte                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	JustAString string                 `protobuf:"bytes,2,opt,name=just_a_string,json=justAString,proto3" json:"just_a_string,omitempty"`
	ADouble     float64                `protobuf:"fixed64,3,opt,name=a_double,json=aDouble,proto3" json:"a_double,omitempty"`
	TestTime    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=test_time,json=testTime,proto3" json:"test_time,omitempty"`
	TestMap     map[string]int32       `` /* 171-byte string literal not displayed */
	TestList    []bool                 `protobuf:"varint,6,rep,packed,name=test_list,json=testList,proto3" json:"test_list,omitempty"`
	// contains filtered or unexported fields
}

func (*TestModel) Descriptor

func (*TestModel) Descriptor() ([]byte, []int)

Deprecated: Use TestModel.ProtoReflect.Descriptor instead.

func (*TestModel) GetADouble

func (x *TestModel) GetADouble() float64

func (*TestModel) GetJustAString

func (x *TestModel) GetJustAString() string

func (*TestModel) GetName

func (x *TestModel) GetName() []byte

func (*TestModel) GetTestList

func (x *TestModel) GetTestList() []bool

func (*TestModel) GetTestMap

func (x *TestModel) GetTestMap() map[string]int32

func (*TestModel) GetTestTime

func (x *TestModel) GetTestTime() *timestamppb.Timestamp

func (*TestModel) ProtoMessage

func (*TestModel) ProtoMessage()

func (*TestModel) ProtoReflect

func (x *TestModel) ProtoReflect() protoreflect.Message

func (*TestModel) Reset

func (x *TestModel) Reset()

func (*TestModel) String

func (x *TestModel) String() string