Versions in this module Expand all Collapse all v0 v0.0.1 Nov 27, 2018 Changes in this version + func GetPathForRedologFile(prefix, table string, shardID int, creationTime int64) string + func GetPathForTableArchiveBatchColumnFile(prefix, table string, shardID int, batchID string, batchVersion uint32, ...) string + func GetPathForTableArchiveBatchDir(prefix, table string, shardID int, batchID string, batchVersion uint32, ...) string + func GetPathForTableArchiveBatchRootDir(prefix, table string, shardID int) string + func GetPathForTableRedologs(prefix, table string, shardID int) string + func GetPathForTableSnapshotBatchDir(prefix, table string, shardID int, redoLogFile int64, offset uint32, ...) string + func GetPathForTableSnapshotColumnFilePath(prefix, table string, shardID int, redoLogFile int64, offset uint32, ...) string + func GetPathForTableSnapshotDir(prefix, table string, shardID int) string + func GetPathForTableSnapshotDirPath(prefix, table string, shardID int, redoLogFile int64, offset uint32) string + func ParseBatchIDAndVersionName(batchIDAndVersion string) (string, uint32, uint32, error) + type DiskStore interface + DeleteBatchVersions func(table string, shard, batchID int, batchVersion uint32, seqNum uint32) error + DeleteBatches func(table string, shard, batchIDStart, batchIDEnd int) (int, error) + DeleteColumn func(table string, column, shard int) error + DeleteLogFile func(table string, shard int, creationTime int64) error + DeleteSnapshot func(table string, shard int, redoLogFile int64, offset uint32) error + DeleteTableShard func(table string, shard int) error + ListLogFiles func(table string, shard int) ([]int64, error) + ListSnapshotBatches func(table string, shard int, redoLogFile int64, offset uint32) ([]int, error) + ListSnapshotVectorPartyFiles func(table string, shard int, redoLogFile int64, offset uint32, batchID int) ([]int, error) + OpenLogFileForAppend func(table string, shard int, creationTime int64) (io.WriteCloser, error) + OpenLogFileForReplay func(table string, shard int, creationTime int64) (utils.ReaderSeekerCloser, error) + OpenSnapshotVectorPartyFileForRead func(table string, shard int, redoLogFile int64, offset uint32, batchID int, ...) (io.ReadCloser, error) + OpenSnapshotVectorPartyFileForWrite func(table string, shard int, redoLogFile int64, offset uint32, batchID int, ...) (io.WriteCloser, error) + OpenVectorPartyFileForRead func(table string, column, shard, batchID int, batchVersion uint32, seqNum uint32) (io.ReadCloser, error) + OpenVectorPartyFileForWrite func(table string, column, shard, batchID int, batchVersion uint32, seqNum uint32) (io.WriteCloser, error) + TruncateLogFile func(table string, shard int, creationTime int64, offset int64) error + func NewLocalDiskStore(rootPath string) DiskStore + type LocalDiskStore struct + func (l LocalDiskStore) DeleteBatchVersions(table string, shard, batchID int, batchVersion uint32, seqNum uint32) error + func (l LocalDiskStore) DeleteBatches(table string, shard, batchIDStart, batchIDEnd int) (int, error) + func (l LocalDiskStore) DeleteColumn(table string, columnID int, shard int) error + func (l LocalDiskStore) DeleteLogFile(table string, shard int, creationTime int64) error + func (l LocalDiskStore) DeleteSnapshot(table string, shard int, latestRedoLogFile int64, latestOffset uint32) error + func (l LocalDiskStore) DeleteTableShard(table string, shard int) error + func (l LocalDiskStore) ListLogFiles(table string, shard int) (creationUnixTime []int64, err error) + func (l LocalDiskStore) ListSnapshotBatches(table string, shard int, redoLogFile int64, offset uint32) (batches []int, err error) + func (l LocalDiskStore) ListSnapshotVectorPartyFiles(table string, shard int, redoLogFile int64, offset uint32, batchID int) (columnIDs []int, err error) + func (l LocalDiskStore) OpenLogFileForAppend(table string, shard int, creationTime int64) (io.WriteCloser, error) + func (l LocalDiskStore) OpenLogFileForReplay(table string, shard int, creationTime int64) (utils.ReaderSeekerCloser, error) + func (l LocalDiskStore) OpenSnapshotVectorPartyFileForRead(table string, shard int, redoLogFile int64, offset uint32, batchID int, ...) (io.ReadCloser, error) + func (l LocalDiskStore) OpenSnapshotVectorPartyFileForWrite(table string, shard int, redoLogFile int64, offset uint32, batchID int, ...) (io.WriteCloser, error) + func (l LocalDiskStore) OpenVectorPartyFileForRead(table string, columnID int, shard, batchID int, batchVersion uint32, ...) (io.ReadCloser, error) + func (l LocalDiskStore) OpenVectorPartyFileForWrite(table string, columnID int, shard, batchID int, batchVersion uint32, ...) (io.WriteCloser, error) + func (l LocalDiskStore) TruncateLogFile(table string, shard int, creationTime int64, offset int64) error
Go to main page