Documentation ¶
Overview ¶
Code generated by mockery v1.0.0. DO NOT EDIT.
Code generated by mockery v1.0.0 ¶
Code generated by mockery v1.0.0. DO NOT EDIT.
Code generated by mockery v1.0.0. DO NOT EDIT.
Code generated by mockery v1.0.0
Index ¶
- type BootStrapToken
- type EnumUpdater
- type HostMemoryManager
- func (_m *HostMemoryManager) GetArchiveMemoryUsageByTableShard() (map[string]map[string]*common.ColumnMemoryUsage, error)
- func (_m *HostMemoryManager) ReportManagedObject(table string, shard int, batchID int, columnID int, bytes int64)
- func (_m *HostMemoryManager) ReportUnmanagedSpaceUsageChange(bytes int64)
- func (_m *HostMemoryManager) Start()
- func (_m *HostMemoryManager) Stop()
- func (_m *HostMemoryManager) TriggerEviction()
- func (_m *HostMemoryManager) TriggerPreload(tableName string, columnID int, oldPreloadingDays int, newPreloadingDays int)
- type ListVectorParty
- type LiveVectorParty
- func (_m *LiveVectorParty) Allocate(hasCount bool)
- func (_m *LiveVectorParty) AsList() common.ListVectorParty
- func (_m *LiveVectorParty) Dump(file *os.File)
- func (_m *LiveVectorParty) Equals(other common.VectorParty) bool
- func (_m *LiveVectorParty) GetBytes() int64
- func (_m *LiveVectorParty) GetDataType() common.DataType
- func (_m *LiveVectorParty) GetDataValue(offset int) common.DataValue
- func (_m *LiveVectorParty) GetDataValueByRow(row int) common.DataValue
- func (_m *LiveVectorParty) GetLength() int
- func (_m *LiveVectorParty) GetMinMaxValue() (uint32, uint32)
- func (_m *LiveVectorParty) GetNonDefaultValueCount() int
- func (_m *LiveVectorParty) GetValidity(offset int) bool
- func (_m *LiveVectorParty) GetValue(offset int) (unsafe.Pointer, bool)
- func (_m *LiveVectorParty) IsList() bool
- func (_m *LiveVectorParty) Read(reader io.Reader, serializer common.VectorPartySerializer) error
- func (_m *LiveVectorParty) SafeDestruct()
- func (_m *LiveVectorParty) SetBool(offset int, val bool, valid bool)
- func (_m *LiveVectorParty) SetDataValue(offset int, value common.DataValue, ...)
- func (_m *LiveVectorParty) SetGoValue(offset int, val common.GoDataValue, valid bool)
- func (_m *LiveVectorParty) SetValue(offset int, val unsafe.Pointer, valid bool)
- func (_m *LiveVectorParty) Slice(startRow int, numRows int) common.SlicedVector
- func (_m *LiveVectorParty) Write(writer io.Writer) error
- type PrimaryKey
- func (_m *PrimaryKey) AllocatedBytes() uint
- func (_m *PrimaryKey) Capacity() uint
- func (_m *PrimaryKey) Delete(key common.Key)
- func (_m *PrimaryKey) Destruct()
- func (_m *PrimaryKey) Find(key common.Key) (common.RecordID, bool)
- func (_m *PrimaryKey) FindOrInsert(key common.Key, value common.RecordID, eventTime uint32) (bool, common.RecordID, error)
- func (_m *PrimaryKey) GetEventTimeCutoff() uint32
- func (_m *PrimaryKey) LockForTransfer() common.PrimaryKeyData
- func (_m *PrimaryKey) Size() uint
- func (_m *PrimaryKey) UnlockAfterTransfer()
- func (_m *PrimaryKey) Update(key common.Key, value common.RecordID) bool
- func (_m *PrimaryKey) UpdateEventTimeCutoff(eventTimeCutoff uint32)
- type TableSchemaReader
- func (_m *TableSchemaReader) GetSchema(table string) (*common.TableSchema, error)
- func (_m *TableSchemaReader) GetSchemas() map[string]*common.TableSchema
- func (_m *TableSchemaReader) Lock()
- func (_m *TableSchemaReader) RLock()
- func (_m *TableSchemaReader) RUnlock()
- func (_m *TableSchemaReader) Unlock()
- type VectorParty
- func (_m *VectorParty) Allocate(hasCount bool)
- func (_m *VectorParty) AsList() common.ListVectorParty
- func (_m *VectorParty) Dump(file *os.File)
- func (_m *VectorParty) Equals(other common.VectorParty) bool
- func (_m *VectorParty) GetBytes() int64
- func (_m *VectorParty) GetDataType() common.DataType
- func (_m *VectorParty) GetDataValue(offset int) common.DataValue
- func (_m *VectorParty) GetDataValueByRow(row int) common.DataValue
- func (_m *VectorParty) GetLength() int
- func (_m *VectorParty) GetNonDefaultValueCount() int
- func (_m *VectorParty) GetValidity(offset int) bool
- func (_m *VectorParty) IsList() bool
- func (_m *VectorParty) Read(reader io.Reader, serializer common.VectorPartySerializer) error
- func (_m *VectorParty) SafeDestruct()
- func (_m *VectorParty) SetDataValue(offset int, value common.DataValue, ...)
- func (_m *VectorParty) Slice(startRow int, numRows int) common.SlicedVector
- func (_m *VectorParty) Write(writer io.Writer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BootStrapToken ¶ added in v0.0.2
BootStrapToken is an autogenerated mock type for the BootStrapToken type
func (*BootStrapToken) AcquireToken ¶ added in v0.0.2
func (_m *BootStrapToken) AcquireToken(table string, shard uint32) bool
AcquireToken provides a mock function with given fields: table, shard
func (*BootStrapToken) ReleaseToken ¶ added in v0.0.2
func (_m *BootStrapToken) ReleaseToken(table string, shard uint32)
ReleaseToken provides a mock function with given fields: table, shard
type EnumUpdater ¶ added in v0.0.2
EnumUpdater is an autogenerated mock type for the EnumUpdater type
func (*EnumUpdater) UpdateEnum ¶ added in v0.0.2
func (_m *EnumUpdater) UpdateEnum(table string, column string, enumList []string) error
UpdateEnum provides a mock function with given fields: table, column, enumList
type HostMemoryManager ¶
HostMemoryManager is an autogenerated mock type for the HostMemoryManager type
func (*HostMemoryManager) GetArchiveMemoryUsageByTableShard ¶
func (_m *HostMemoryManager) GetArchiveMemoryUsageByTableShard() (map[string]map[string]*common.ColumnMemoryUsage, error)
GetArchiveMemoryUsageByTableShard provides a mock function with given fields:
func (*HostMemoryManager) ReportManagedObject ¶
func (_m *HostMemoryManager) ReportManagedObject(table string, shard int, batchID int, columnID int, bytes int64)
ReportManagedObject provides a mock function with given fields: table, shard, batchID, columnID, bytes
func (*HostMemoryManager) ReportUnmanagedSpaceUsageChange ¶
func (_m *HostMemoryManager) ReportUnmanagedSpaceUsageChange(bytes int64)
ReportUnmanagedSpaceUsageChange provides a mock function with given fields: bytes
func (*HostMemoryManager) Start ¶
func (_m *HostMemoryManager) Start()
Start provides a mock function with given fields:
func (*HostMemoryManager) Stop ¶
func (_m *HostMemoryManager) Stop()
Stop provides a mock function with given fields:
func (*HostMemoryManager) TriggerEviction ¶
func (_m *HostMemoryManager) TriggerEviction()
TriggerEviction provides a mock function with given fields:
func (*HostMemoryManager) TriggerPreload ¶
func (_m *HostMemoryManager) TriggerPreload(tableName string, columnID int, oldPreloadingDays int, newPreloadingDays int)
TriggerPreload provides a mock function with given fields: tableName, columnID, oldPreloadingDays, newPreloadingDays
type ListVectorParty ¶ added in v0.0.2
ListVectorParty is an autogenerated mock type for the ListVectorParty type
func (*ListVectorParty) GetListValue ¶ added in v0.0.2
func (_m *ListVectorParty) GetListValue(row int) (unsafe.Pointer, bool)
GetListValue provides a mock function with given fields: row
func (*ListVectorParty) SetListValue ¶ added in v0.0.2
func (_m *ListVectorParty) SetListValue(row int, val unsafe.Pointer, valid bool)
SetListValue provides a mock function with given fields: row, val, valid
type LiveVectorParty ¶
LiveVectorParty is an autogenerated mock type for the LiveVectorParty type
func (*LiveVectorParty) Allocate ¶
func (_m *LiveVectorParty) Allocate(hasCount bool)
Allocate provides a mock function with given fields: hasCount
func (*LiveVectorParty) AsList ¶ added in v0.0.2
func (_m *LiveVectorParty) AsList() common.ListVectorParty
AsList provides a mock function with given fields:
func (*LiveVectorParty) Dump ¶ added in v0.0.2
func (_m *LiveVectorParty) Dump(file *os.File)
Dump provides a mock function with given fields: file
func (*LiveVectorParty) Equals ¶
func (_m *LiveVectorParty) Equals(other common.VectorParty) bool
Equals provides a mock function with given fields: other
func (*LiveVectorParty) GetBytes ¶
func (_m *LiveVectorParty) GetBytes() int64
GetBytes provides a mock function with given fields:
func (*LiveVectorParty) GetDataType ¶
func (_m *LiveVectorParty) GetDataType() common.DataType
GetDataType provides a mock function with given fields:
func (*LiveVectorParty) GetDataValue ¶
func (_m *LiveVectorParty) GetDataValue(offset int) common.DataValue
GetDataValue provides a mock function with given fields: offset
func (*LiveVectorParty) GetDataValueByRow ¶
func (_m *LiveVectorParty) GetDataValueByRow(row int) common.DataValue
GetDataValueByRow provides a mock function with given fields: row
func (*LiveVectorParty) GetLength ¶
func (_m *LiveVectorParty) GetLength() int
GetLength provides a mock function with given fields:
func (*LiveVectorParty) GetMinMaxValue ¶
func (_m *LiveVectorParty) GetMinMaxValue() (uint32, uint32)
GetMinMaxValue provides a mock function with given fields:
func (*LiveVectorParty) GetNonDefaultValueCount ¶
func (_m *LiveVectorParty) GetNonDefaultValueCount() int
GetNonDefaultValueCount provides a mock function with given fields:
func (*LiveVectorParty) GetValidity ¶
func (_m *LiveVectorParty) GetValidity(offset int) bool
GetValidity provides a mock function with given fields: offset
func (*LiveVectorParty) GetValue ¶ added in v0.0.2
func (_m *LiveVectorParty) GetValue(offset int) (unsafe.Pointer, bool)
GetValue provides a mock function with given fields: offset
func (*LiveVectorParty) IsList ¶ added in v0.0.2
func (_m *LiveVectorParty) IsList() bool
IsList provides a mock function with given fields:
func (*LiveVectorParty) Read ¶
func (_m *LiveVectorParty) Read(reader io.Reader, serializer common.VectorPartySerializer) error
Read provides a mock function with given fields: reader, serializer
func (*LiveVectorParty) SafeDestruct ¶
func (_m *LiveVectorParty) SafeDestruct()
SafeDestruct provides a mock function with given fields:
func (*LiveVectorParty) SetBool ¶ added in v0.0.2
func (_m *LiveVectorParty) SetBool(offset int, val bool, valid bool)
SetBool provides a mock function with given fields: offset, val, valid
func (*LiveVectorParty) SetDataValue ¶
func (_m *LiveVectorParty) SetDataValue(offset int, value common.DataValue, countsUpdateMode common.ValueCountsUpdateMode, counts ...uint32)
SetDataValue provides a mock function with given fields: offset, value, countsUpdateMode, counts
func (*LiveVectorParty) SetGoValue ¶ added in v0.0.2
func (_m *LiveVectorParty) SetGoValue(offset int, val common.GoDataValue, valid bool)
SetGoValue provides a mock function with given fields: offset, val, valid
func (*LiveVectorParty) SetValue ¶ added in v0.0.2
func (_m *LiveVectorParty) SetValue(offset int, val unsafe.Pointer, valid bool)
SetValue provides a mock function with given fields: offset, val, valid
func (*LiveVectorParty) Slice ¶
func (_m *LiveVectorParty) Slice(startRow int, numRows int) common.SlicedVector
Slice provides a mock function with given fields: startRow, numRows
type PrimaryKey ¶ added in v0.0.2
PrimaryKey is an autogenerated mock type for the PrimaryKey type
func (*PrimaryKey) AllocatedBytes ¶ added in v0.0.2
func (_m *PrimaryKey) AllocatedBytes() uint
AllocatedBytes provides a mock function with given fields:
func (*PrimaryKey) Capacity ¶ added in v0.0.2
func (_m *PrimaryKey) Capacity() uint
Capacity provides a mock function with given fields:
func (*PrimaryKey) Delete ¶ added in v0.0.2
func (_m *PrimaryKey) Delete(key common.Key)
Delete provides a mock function with given fields: key
func (*PrimaryKey) Destruct ¶ added in v0.0.2
func (_m *PrimaryKey) Destruct()
Destruct provides a mock function with given fields:
func (*PrimaryKey) FindOrInsert ¶ added in v0.0.2
func (_m *PrimaryKey) FindOrInsert(key common.Key, value common.RecordID, eventTime uint32) (bool, common.RecordID, error)
FindOrInsert provides a mock function with given fields: key, value, eventTime
func (*PrimaryKey) GetEventTimeCutoff ¶ added in v0.0.2
func (_m *PrimaryKey) GetEventTimeCutoff() uint32
GetEventTimeCutoff provides a mock function with given fields:
func (*PrimaryKey) LockForTransfer ¶ added in v0.0.2
func (_m *PrimaryKey) LockForTransfer() common.PrimaryKeyData
LockForTransfer provides a mock function with given fields:
func (*PrimaryKey) Size ¶ added in v0.0.2
func (_m *PrimaryKey) Size() uint
Size provides a mock function with given fields:
func (*PrimaryKey) UnlockAfterTransfer ¶ added in v0.0.2
func (_m *PrimaryKey) UnlockAfterTransfer()
UnlockAfterTransfer provides a mock function with given fields:
func (*PrimaryKey) Update ¶ added in v0.0.2
Update provides a mock function with given fields: key, value
func (*PrimaryKey) UpdateEventTimeCutoff ¶ added in v0.0.2
func (_m *PrimaryKey) UpdateEventTimeCutoff(eventTimeCutoff uint32)
UpdateEventTimeCutoff provides a mock function with given fields: eventTimeCutoff
type TableSchemaReader ¶ added in v0.0.2
TableSchemaReader is an autogenerated mock type for the TableSchemaReader type
func (*TableSchemaReader) GetSchema ¶ added in v0.0.2
func (_m *TableSchemaReader) GetSchema(table string) (*common.TableSchema, error)
GetSchema provides a mock function with given fields: table
func (*TableSchemaReader) GetSchemas ¶ added in v0.0.2
func (_m *TableSchemaReader) GetSchemas() map[string]*common.TableSchema
GetSchemas provides a mock function with given fields:
func (*TableSchemaReader) Lock ¶ added in v0.0.2
func (_m *TableSchemaReader) Lock()
Lock provides a mock function with given fields:
func (*TableSchemaReader) RLock ¶ added in v0.0.2
func (_m *TableSchemaReader) RLock()
RLock provides a mock function with given fields:
func (*TableSchemaReader) RUnlock ¶ added in v0.0.2
func (_m *TableSchemaReader) RUnlock()
RUnlock provides a mock function with given fields:
func (*TableSchemaReader) Unlock ¶ added in v0.0.2
func (_m *TableSchemaReader) Unlock()
Unlock provides a mock function with given fields:
type VectorParty ¶
VectorParty is an autogenerated mock type for the VectorParty type
func (*VectorParty) Allocate ¶
func (_m *VectorParty) Allocate(hasCount bool)
Allocate provides a mock function with given fields: hasCount
func (*VectorParty) AsList ¶ added in v0.0.2
func (_m *VectorParty) AsList() common.ListVectorParty
AsList provides a mock function with given fields:
func (*VectorParty) Dump ¶ added in v0.0.2
func (_m *VectorParty) Dump(file *os.File)
Dump provides a mock function with given fields: file
func (*VectorParty) Equals ¶
func (_m *VectorParty) Equals(other common.VectorParty) bool
Equals provides a mock function with given fields: other
func (*VectorParty) GetBytes ¶
func (_m *VectorParty) GetBytes() int64
GetBytes provides a mock function with given fields:
func (*VectorParty) GetDataType ¶
func (_m *VectorParty) GetDataType() common.DataType
GetDataType provides a mock function with given fields:
func (*VectorParty) GetDataValue ¶
func (_m *VectorParty) GetDataValue(offset int) common.DataValue
GetDataValue provides a mock function with given fields: offset
func (*VectorParty) GetDataValueByRow ¶
func (_m *VectorParty) GetDataValueByRow(row int) common.DataValue
GetDataValueByRow provides a mock function with given fields: row
func (*VectorParty) GetLength ¶
func (_m *VectorParty) GetLength() int
GetLength provides a mock function with given fields:
func (*VectorParty) GetNonDefaultValueCount ¶
func (_m *VectorParty) GetNonDefaultValueCount() int
GetNonDefaultValueCount provides a mock function with given fields:
func (*VectorParty) GetValidity ¶
func (_m *VectorParty) GetValidity(offset int) bool
GetValidity provides a mock function with given fields: offset
func (*VectorParty) IsList ¶ added in v0.0.2
func (_m *VectorParty) IsList() bool
IsList provides a mock function with given fields:
func (*VectorParty) Read ¶
func (_m *VectorParty) Read(reader io.Reader, serializer common.VectorPartySerializer) error
Read provides a mock function with given fields: reader, serializer
func (*VectorParty) SafeDestruct ¶
func (_m *VectorParty) SafeDestruct()
SafeDestruct provides a mock function with given fields:
func (*VectorParty) SetDataValue ¶
func (_m *VectorParty) SetDataValue(offset int, value common.DataValue, countsUpdateMode common.ValueCountsUpdateMode, counts ...uint32)
SetDataValue provides a mock function with given fields: offset, value, countsUpdateMode, counts
func (*VectorParty) Slice ¶
func (_m *VectorParty) Slice(startRow int, numRows int) common.SlicedVector
Slice provides a mock function with given fields: startRow, numRows