Package one.microstream.afs.blobstore

Class BlobStoreConnector.Abstract<B>

java.lang.Object

one.microstream.afs.blobstore.BlobStoreConnector.Abstract<B>

Type Parameters:

B - the blob type

All Implemented Interfaces:

AutoCloseable, BlobStoreConnector

Direct Known Subclasses:

AzureStorageConnector.Default, CoherenceConnector.Default, DynamoDbConnector.Default, HazelcastConnector.Default, KafkaConnector.Default, MongoDbConnector.Default, MongoDbConnector.GridFs, OracleCloudObjectStorageConnector.Default, OracleNoSqlConnector.Default, RedisConnector.Default, S3Connector.Default

Enclosing interface:

BlobStoreConnector

public abstract static class BlobStoreConnector.Abstract<B>
extends Object
implements BlobStoreConnector

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.afs.blobstore.BlobStoreConnector

BlobStoreConnector.Abstract<B>

Constructor Summary

Constructors

Constructor	Description
Abstract()

Method Summary

Modifier and Type	Method	Description
void	close()
long	copyFile(BlobStorePath sourceFile, BlobStorePath targetFile, long offset, long length)
boolean	createDirectory(BlobStorePath directory)
boolean	createFile(BlobStorePath file)
boolean	deleteFile(BlobStorePath file)
boolean	directoryExists(BlobStorePath directory)
boolean	fileExists(BlobStorePath file)
long	fileSize(BlobStorePath file)
void	moveFile(BlobStorePath sourceFile, BlobStorePath targetFile)
ByteBuffer	readData(BlobStorePath file, long offset, long length)
long	readData(BlobStorePath file, ByteBuffer targetBuffer, long offset, long length)
void	truncateFile(BlobStorePath file, long newLength)
void	visitChildren(BlobStorePath directory, BlobStorePathVisitor visitor)
long	writeData(BlobStorePath file, Iterable<? extends ByteBuffer> sourceBuffers)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Abstract

public Abstract()

Method Details

fileSize

public final long fileSize(BlobStorePath file)

Specified by:

fileSize in interface BlobStoreConnector

directoryExists

public final boolean directoryExists(BlobStorePath directory)

Specified by:

directoryExists in interface BlobStoreConnector

fileExists

public final boolean fileExists(BlobStorePath file)

Specified by:

fileExists in interface BlobStoreConnector

visitChildren

public void visitChildren(BlobStorePath directory, BlobStorePathVisitor visitor)

Specified by:

visitChildren in interface BlobStoreConnector

createDirectory

public final boolean createDirectory(BlobStorePath directory)

Specified by:

createDirectory in interface BlobStoreConnector

createFile

public final boolean createFile(BlobStorePath file)

Specified by:

createFile in interface BlobStoreConnector

deleteFile

public final boolean deleteFile(BlobStorePath file)

Specified by:

deleteFile in interface BlobStoreConnector

readData

public final ByteBuffer readData(BlobStorePath file, long offset, long length)

Specified by:

readData in interface BlobStoreConnector

readData

public final long readData(BlobStorePath file, ByteBuffer targetBuffer, long offset, long length)

Specified by:

readData in interface BlobStoreConnector

writeData

public final long writeData(BlobStorePath file, Iterable<? extends ByteBuffer> sourceBuffers)

Specified by:

writeData in interface BlobStoreConnector

moveFile

public final void moveFile(BlobStorePath sourceFile, BlobStorePath targetFile)

Specified by:

moveFile in interface BlobStoreConnector

copyFile

public final long copyFile(BlobStorePath sourceFile, BlobStorePath targetFile, long offset, long length)

Specified by:

copyFile in interface BlobStoreConnector

truncateFile

public void truncateFile(BlobStorePath file, long newLength)

Specified by:

truncateFile in interface BlobStoreConnector

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BlobStoreConnector