store

func (*CompressedEncryptedStore) DownloadFromS3 ¶

func (c *CompressedEncryptedStore) DownloadFromS3(cur *cursor.Cursor, s3Manager *scalablestore.S3Manager) bool

func (*CompressedEncryptedStore) ExtractToSeekableStore ¶

func (c *CompressedEncryptedStore) ExtractToSeekableStore(cur *cursor.Cursor, seekableStore *SeekableStore) bool

extracts compressed file first to temporary filename and then atomically moves it to SeekableStore

func (*CompressedEncryptedStore) Has ¶

func (c *CompressedEncryptedStore) Has(cur *cursor.Cursor) bool

TODO: this has a race condition. remove this

func (*CompressedEncryptedStore) SaveFromLiveFile ¶

func (c *CompressedEncryptedStore) SaveFromLiveFile(cur *cursor.Cursor, fromFd *os.File) error

stores the file as compressed & encrypted file from WAL's live file. when passing the FD, make sure fseek(0)

func (*CompressedEncryptedStore) UploadToS3 ¶

func (c *CompressedEncryptedStore) UploadToS3(cur *cursor.Cursor, s3Manager *scalablestore.S3Manager) error

upload compressed&encrypted to S3. only done once (or in rare cases more if upload errors)

func (*SeekableStore) Has ¶

func (s *SeekableStore) Has(cursor *cursor.Cursor) bool

func (*SeekableStore) Open ¶

func (s *SeekableStore) Open(cursor *cursor.Cursor) (*os.File, error)

func (*SeekableStore) SaveByRenaming ¶

func (s *SeekableStore) SaveByRenaming(cursor *cursor.Cursor, fromPath string)

store a file in SeekableStore by renaming a file here from a temporary location, so we can do this in an atomic way (= the second Has() reports true we have 100 % complete file)