Package one.microstream.afs.blobstore
Interface BlobStoreConnector
- All Superinterfaces:
AutoCloseable
- All Known Subinterfaces:
AzureStorageConnector
,CoherenceConnector
,DynamoDbConnector
,HazelcastConnector
,KafkaConnector
,MongoDbConnector
,OracleCloudObjectStorageConnector
,OracleNoSqlConnector
,RedisConnector
,S3Connector
- All Known Implementing Classes:
AzureStorageConnector.Default
,BlobStoreConnector.Abstract
,CoherenceConnector.Default
,DynamoDbConnector.Default
,HazelcastConnector.Default
,KafkaConnector.Default
,MongoDbConnector.Default
,MongoDbConnector.GridFs
,OracleCloudObjectStorageConnector.Default
,OracleNoSqlConnector.Default
,RedisConnector.Default
,S3Connector.Default
public interface BlobStoreConnector extends AutoCloseable
Connector for blob stores which handles the concrete IO operations on a specific connection.
All operations must be implemented thread-safe.
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
BlobStoreConnector.Abstract<B>
-
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)
-
Method Details
-
fileSize
-
directoryExists
-
fileExists
-
visitChildren
-
createDirectory
-
createFile
-
deleteFile
-
readData
-
readData
-
writeData
-
moveFile
-
copyFile
-
truncateFile
-
close
void close()- Specified by:
close
in interfaceAutoCloseable
-