Documentation
¶
Index ¶
- type DiskStore
- func (_m *DiskStore) DeleteBatchVersions(table string, shard int, batchID int, batchVersion uint32, seqNum uint32) error
- func (_m *DiskStore) DeleteBatches(table string, shard int, batchIDStart int, batchIDEnd int) (int, error)
- func (_m *DiskStore) DeleteColumn(table string, column int, shard int) error
- func (_m *DiskStore) DeleteLogFile(table string, shard int, creationTime int64) error
- func (_m *DiskStore) DeleteSnapshot(table string, shard int, redoLogFile int64, offset uint32) error
- func (_m *DiskStore) DeleteTableShard(table string, shard int) error
- func (_m *DiskStore) ListArchiveBatchVectorPartyFiles(table string, shard int, batchID int, batchVersion uint32, seqNum uint32) ([]int, error)
- func (_m *DiskStore) ListLogFiles(table string, shard int) ([]int64, error)
- func (_m *DiskStore) ListSnapshotBatches(table string, shard int, redoLogFile int64, offset uint32) ([]int, error)
- func (_m *DiskStore) ListSnapshotVectorPartyFiles(table string, shard int, redoLogFile int64, offset uint32, batchID int) ([]int, error)
- func (_m *DiskStore) OpenLogFileForAppend(table string, shard int, creationTime int64) (io.WriteCloser, error)
- func (_m *DiskStore) OpenLogFileForReplay(table string, shard int, creationTime int64) (utils.ReaderSeekerCloser, error)
- func (_m *DiskStore) OpenSnapshotVectorPartyFileForRead(table string, shard int, redoLogFile int64, offset uint32, batchID int, ...) (io.ReadCloser, error)
- func (_m *DiskStore) OpenSnapshotVectorPartyFileForWrite(table string, shard int, redoLogFile int64, offset uint32, batchID int, ...) (io.WriteCloser, error)
- func (_m *DiskStore) OpenVectorPartyFileForRead(table string, column int, shard int, batchID int, batchVersion uint32, ...) (io.ReadCloser, error)
- func (_m *DiskStore) OpenVectorPartyFileForWrite(table string, column int, shard int, batchID int, batchVersion uint32, ...) (io.WriteCloser, error)
- func (_m *DiskStore) TruncateLogFile(table string, shard int, creationTime int64, offset int64) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DiskStore ¶
DiskStore is an autogenerated mock type for the DiskStore type
func (*DiskStore) DeleteBatchVersions ¶
func (_m *DiskStore) DeleteBatchVersions(table string, shard int, batchID int, batchVersion uint32, seqNum uint32) error
DeleteBatchVersions provides a mock function with given fields: table, shard, batchID, batchVersion, seqNum
func (*DiskStore) DeleteBatches ¶
func (_m *DiskStore) DeleteBatches(table string, shard int, batchIDStart int, batchIDEnd int) (int, error)
DeleteBatches provides a mock function with given fields: table, shard, batchIDStart, batchIDEnd
func (*DiskStore) DeleteColumn ¶
DeleteColumn provides a mock function with given fields: table, column, shard
func (*DiskStore) DeleteLogFile ¶
DeleteLogFile provides a mock function with given fields: table, shard, creationTime
func (*DiskStore) DeleteSnapshot ¶
func (_m *DiskStore) DeleteSnapshot(table string, shard int, redoLogFile int64, offset uint32) error
DeleteSnapshot provides a mock function with given fields: table, shard, redoLogFile, offset
func (*DiskStore) DeleteTableShard ¶
DeleteTableShard provides a mock function with given fields: table, shard
func (*DiskStore) ListArchiveBatchVectorPartyFiles ¶ added in v0.0.2
func (_m *DiskStore) ListArchiveBatchVectorPartyFiles(table string, shard int, batchID int, batchVersion uint32, seqNum uint32) ([]int, error)
ListArchiveBatchVectorPartyFiles provides a mock function with given fields: table, shard, batchID, batchVersion, seqNum
func (*DiskStore) ListLogFiles ¶
ListLogFiles provides a mock function with given fields: table, shard
func (*DiskStore) ListSnapshotBatches ¶
func (_m *DiskStore) ListSnapshotBatches(table string, shard int, redoLogFile int64, offset uint32) ([]int, error)
ListSnapshotBatches provides a mock function with given fields: table, shard, redoLogFile, offset
func (*DiskStore) ListSnapshotVectorPartyFiles ¶
func (_m *DiskStore) ListSnapshotVectorPartyFiles(table string, shard int, redoLogFile int64, offset uint32, batchID int) ([]int, error)
ListSnapshotVectorPartyFiles provides a mock function with given fields: table, shard, redoLogFile, offset, batchID
func (*DiskStore) OpenLogFileForAppend ¶
func (_m *DiskStore) OpenLogFileForAppend(table string, shard int, creationTime int64) (io.WriteCloser, error)
OpenLogFileForAppend provides a mock function with given fields: table, shard, creationTime
func (*DiskStore) OpenLogFileForReplay ¶
func (_m *DiskStore) OpenLogFileForReplay(table string, shard int, creationTime int64) (utils.ReaderSeekerCloser, error)
OpenLogFileForReplay provides a mock function with given fields: table, shard, creationTime
func (*DiskStore) OpenSnapshotVectorPartyFileForRead ¶
func (_m *DiskStore) OpenSnapshotVectorPartyFileForRead(table string, shard int, redoLogFile int64, offset uint32, batchID int, columnID int) (io.ReadCloser, error)
OpenSnapshotVectorPartyFileForRead provides a mock function with given fields: table, shard, redoLogFile, offset, batchID, columnID
func (*DiskStore) OpenSnapshotVectorPartyFileForWrite ¶
func (_m *DiskStore) OpenSnapshotVectorPartyFileForWrite(table string, shard int, redoLogFile int64, offset uint32, batchID int, columnID int) (io.WriteCloser, error)
OpenSnapshotVectorPartyFileForWrite provides a mock function with given fields: table, shard, redoLogFile, offset, batchID, columnID
func (*DiskStore) OpenVectorPartyFileForRead ¶
func (_m *DiskStore) OpenVectorPartyFileForRead(table string, column int, shard int, batchID int, batchVersion uint32, seqNum uint32) (io.ReadCloser, error)
OpenVectorPartyFileForRead provides a mock function with given fields: table, column, shard, batchID, batchVersion, seqNum
func (*DiskStore) OpenVectorPartyFileForWrite ¶
func (_m *DiskStore) OpenVectorPartyFileForWrite(table string, column int, shard int, batchID int, batchVersion uint32, seqNum uint32) (io.WriteCloser, error)
OpenVectorPartyFileForWrite provides a mock function with given fields: table, column, shard, batchID, batchVersion, seqNum