diskstore

type DiskStore interface {

	// Completely wipe out a table shard.
	DeleteTableShard(table string, shard int) error

	// Returns the file creation unix time in second for each log file as a sorted slice.
	ListLogFiles(table string, shard int) ([]int64, error)
	// Opens the specified log file for replay.
	OpenLogFileForReplay(table string, shard int, creationTime int64) (utils.ReaderSeekerCloser, error)
	// Opens/creates the specified log file for append.
	OpenLogFileForAppend(table string, shard int, creationTime int64) (io.WriteCloser, error)
	// Deletes the specified log file.
	DeleteLogFile(table string, shard int, creationTime int64) error
	// Truncate Redolog to drop the last incomplete/corrupted upsert batch.
	TruncateLogFile(table string, shard int, creationTime int64, offset int64) error

	// Returns the batch directories under a specific snapshot directory.
	ListSnapshotBatches(table string, shard int,
		redoLogFile int64, offset uint32) ([]int, error)

	// Returns the vector party files under a specific snapshot batch directory.
	// the return value is sorted
	ListSnapshotVectorPartyFiles(table string, shard int,
		redoLogFile int64, offset uint32, batchID int) ([]int, error)

	// Opens the snapshot vector party file for read.
	OpenSnapshotVectorPartyFileForRead(table string, shard int,
		redoLogFile int64, offset uint32, batchID int, columnID int) (io.ReadCloser, error)

	// Creates/truncates the snapshot column file for write.
	OpenSnapshotVectorPartyFileForWrite(table string, shard int,
		redoLogFile int64, offset uint32, batchID int, columnID int) (io.WriteCloser, error)
	// Deletes snapshot files **older than** the specified version.
	DeleteSnapshot(table string, shard int, redoLogFile int64, offset uint32) error

	// Get all vector party files for a specific batch version/seq
	ListArchiveBatchVectorPartyFiles(table string, shard, batchID int, batchVersion uint32, seqNum uint32) ([]int, error)
	// Opens the vector party file at the specified batchVersion for read.
	OpenVectorPartyFileForRead(table string, column, shard, batchID int, batchVersion uint32,
		seqNum uint32) (io.ReadCloser, error)
	// Creates/truncates the vector party file at the specified batchVersion for write.
	OpenVectorPartyFileForWrite(table string, column, shard, batchID int, batchVersion uint32,
		seqNum uint32) (io.WriteCloser, error)
	// Deletes all old batches with the specified batchID that have version lower than or equal to the specified batch
	// version. All columns of those batches will be deleted.
	DeleteBatchVersions(table string, shard, batchID int, batchVersion uint32, seqNum uint32) error
	// Deletes all batches within range [batchIDStart, batchIDEnd)
	DeleteBatches(table string, shard, batchIDStart, batchIDEnd int) (int, error)
	// Deletes all batches of the specified column.
	DeleteColumn(table string, column, shard int) error
}

type LocalDiskStore struct {
	// contains filtered or unexported fields
}