java.lang.Object

one.microstream.afs.blobstore.types.BlobStoreConnector.Abstract

Type Parameters:: B - the blob type

All Implemented Interfaces:: AutoCloseable, BlobStoreConnector

Direct Known Subclasses:: AzureStorageConnector.Default, DynamoDbConnector.Default, GoogleCloudFirestoreConnector.Default, HazelcastConnector.Default, KafkaConnector.Default, OracleCloudObjectStorageConnector.Default, OracleCoherenceConnector.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.types.BlobStoreConnector
BlobStoreConnector.Abstract

Field Summary

Fields
Modifier and Type	Field	Description
`protected static String`	`NUMBER_SUFFIX_REGEX`
`protected static String`	`NUMBER_SUFFIX_SEPARATOR`
`protected static char`	`NUMBER_SUFFIX_SEPARATOR_CHAR`

Constructor Summary

Constructors
Modifier	Constructor	Description
`protected`	`Abstract(Function<B,String> blobKeyProvider, ToLongFunction<B> blobSizeProvider, boolean useCache)`
`protected`	`Abstract(Function<B,String> blobKeyProvider, ToLongFunction<B> blobSizeProvider, BlobStorePath.Validator blobStorePathValidator, boolean useCache)`

Method Summary

Modifier and Type	Method	Description
`protected Comparator<B>`	`blobComparator()`
`protected static String`	`blobKeyRegex(String prefix)`
`protected long`	`blobNumber(B blob)`
`protected abstract Stream<? extends B>`	`blobs(BlobStorePath file)`
`protected abstract Stream<String>`	`childKeys(BlobStorePath directory)`
`protected static String`	`childKeysRegex(BlobStorePath directory)`
`protected static String`	`childKeysRegexWithContainer(BlobStorePath directory)`
`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)`
`protected static String`	`directoryNameOfKey(String key)`
`protected void`	`ensureOpen()`
`boolean`	`fileExists(BlobStorePath file)`
`protected String`	`fileNameOfKey(String key)`
`long`	`fileSize(BlobStorePath file)`
`protected void`	`internalClose()`
`protected long`	`internalCopyFile(BlobStorePath sourceFile, BlobStorePath targetFile, long offset, long length)`
`protected boolean`	`internalCreateDirectory(BlobStorePath directory)`
`protected boolean`	`internalCreateFile(BlobStorePath file)`
`protected abstract boolean`	`internalDeleteBlobs(BlobStorePath file, List<? extends B> blobs)`
`protected boolean`	`internalDeleteFile(BlobStorePath file)`
`protected boolean`	`internalDirectoryExists(BlobStorePath directory)`
`protected boolean`	`internalFileExists(BlobStorePath file)`
`protected long`	`internalFileSize(BlobStorePath file)`
`protected boolean`	`internalIsEmpty(BlobStorePath directory)`
`protected void`	`internalMoveFile(BlobStorePath sourceFile, BlobStorePath targetFile)`
`protected abstract void`	`internalReadBlobData(BlobStorePath file, B blob, ByteBuffer targetBuffer, long offset, long length)`
`protected ByteBuffer`	`internalReadData(BlobStorePath file, long offset, long length)`
`protected long`	`internalReadData(BlobStorePath file, ByteBuffer targetBuffer, long offset, long length)`
`protected long`	`internalReadData(BlobStorePath file, LongFunction<ByteBuffer> bufferProvider, long offset, long length)`
`protected void`	`internalTruncateFile(BlobStorePath file, long newLength)`
`protected void`	`internalVisitChildren(BlobStorePath directory, BlobStorePathVisitor visitor)`
`protected abstract long`	`internalWriteData(BlobStorePath file, Iterable<? extends ByteBuffer> sourceBuffers)`
`protected static boolean`	`isBlobKey(String key)`
`protected static boolean`	`isDirectoryKey(String key)`
`boolean`	`isEmpty(BlobStorePath directory)`
`void`	`moveFile(BlobStorePath sourceFile, BlobStorePath targetFile)`
`protected long`	`nextBlobNumber(BlobStorePath file)`
`ByteBuffer`	`readData(BlobStorePath file, long offset, long length)`
`long`	`readData(BlobStorePath file, ByteBuffer targetBuffer, long offset, long length)`
`protected static String`	`removeNumberSuffix(String key)`
`protected static String`	`toBlobKey(BlobStorePath file, long nr)`
`protected static String`	`toBlobKeyPrefix(BlobStorePath file)`
`protected static String`	`toBlobKeyPrefixWithContainer(BlobStorePath file)`
`protected static String`	`toBlobKeyWithContainer(BlobStorePath file, long nr)`
`protected static String`	`toChildKeysPrefix(BlobStorePath directory)`
`protected static String`	`toChildKeysPrefixWithContainer(BlobStorePath directory)`
`protected static String`	`toContainerKey(BlobStorePath directory)`
`protected long`	`totalSize(Iterable<? extends ByteBuffer> sourceBuffers)`
`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

Field Details
- NUMBER_SUFFIX_SEPARATOR
  
  protected static final String NUMBER_SUFFIX_SEPARATOR
  
  See Also:
  
  Constant Field Values
- NUMBER_SUFFIX_SEPARATOR_CHAR
  
  protected static final char NUMBER_SUFFIX_SEPARATOR_CHAR
  
  See Also:
  
  Constant Field Values
- NUMBER_SUFFIX_REGEX
  
  protected static final String NUMBER_SUFFIX_REGEX
  
  See Also:
  
  Constant Field Values
Constructor Details
- Abstract
 
 protected Abstract(Function<B,String> blobKeyProvider, ToLongFunction blobSizeProvider, boolean useCache)
- Abstract
 
 protected Abstract(Function<B,String> blobKeyProvider, ToLongFunction blobSizeProvider, BlobStorePath.Validator blobStorePathValidator, boolean useCache)
Method Details
- toContainerKey
 
 protected static String toContainerKey(BlobStorePath directory)
- toBlobKey
 
 protected static String toBlobKey(BlobStorePath file, long nr)
- toBlobKeyWithContainer
 
 protected static String toBlobKeyWithContainer(BlobStorePath file, long nr)
- toBlobKeyPrefix
 
 protected static String toBlobKeyPrefix(BlobStorePath file)
- toBlobKeyPrefixWithContainer
 
 protected static String toBlobKeyPrefixWithContainer(BlobStorePath file)
- blobKeyRegex
 
 protected static String blobKeyRegex(String prefix)
- toChildKeysPrefix
 
 protected static String toChildKeysPrefix(BlobStorePath directory)
- toChildKeysPrefixWithContainer
 
 protected static String toChildKeysPrefixWithContainer(BlobStorePath directory)
- childKeysRegex
 
 protected static String childKeysRegex(BlobStorePath directory)
- childKeysRegexWithContainer
 
 protected static String childKeysRegexWithContainer(BlobStorePath directory)
- removeNumberSuffix
 
 protected static String removeNumberSuffix(String key)
- isBlobKey
 
 protected static boolean isBlobKey(String key)
- isDirectoryKey
 
 protected static boolean isDirectoryKey(String key)
- directoryNameOfKey
 
 protected static String directoryNameOfKey(String key)
- blobs
 
 protected abstract Stream<? extends B> blobs(BlobStorePath file)
- childKeys
 
 protected abstract Stream<String> childKeys(BlobStorePath directory)
- internalDeleteBlobs
 
 protected abstract boolean internalDeleteBlobs(BlobStorePath file, List<? extends B> blobs)
- internalReadBlobData
 
 protected abstract void internalReadBlobData(BlobStorePath file, B blob, ByteBuffer targetBuffer, long offset, long length)
- internalWriteData
 
 protected abstract long internalWriteData(BlobStorePath file, Iterable<? extends ByteBuffer> sourceBuffers)
- internalFileSize
 
 protected long internalFileSize(BlobStorePath file)
- internalDirectoryExists
 
 protected boolean internalDirectoryExists(BlobStorePath directory)
- internalFileExists
 
 protected boolean internalFileExists(BlobStorePath file)
- internalIsEmpty
 
 protected boolean internalIsEmpty(BlobStorePath directory)
- internalVisitChildren
 
 protected void internalVisitChildren(BlobStorePath directory, BlobStorePathVisitor visitor)
- fileNameOfKey
 
 protected String fileNameOfKey(String key)
- internalCreateDirectory
 
 protected boolean internalCreateDirectory(BlobStorePath directory)
- internalCreateFile
 
 protected boolean internalCreateFile(BlobStorePath file)
- internalDeleteFile
 
 protected boolean internalDeleteFile(BlobStorePath file)
- internalReadData
 
 protected ByteBuffer internalReadData(BlobStorePath file, long offset, long length)
- internalReadData
 
 protected long internalReadData(BlobStorePath file, ByteBuffer targetBuffer, long offset, long length)
- internalMoveFile
 
 protected void internalMoveFile(BlobStorePath sourceFile, BlobStorePath targetFile)
- internalCopyFile
 
 protected long internalCopyFile(BlobStorePath sourceFile, BlobStorePath targetFile, long offset, long length)
- internalTruncateFile
 
 protected void internalTruncateFile(BlobStorePath file, long newLength)
- ensureOpen
 
 protected final void ensureOpen()
- internalClose
 
 protected void internalClose()
- blobComparator
 
 protected Comparator blobComparator()
- blobNumber
 
 protected long blobNumber(B blob)
- nextBlobNumber
 
 protected long nextBlobNumber(BlobStorePath file)
- internalReadData
 
 protected long internalReadData(BlobStorePath file, LongFunction<ByteBuffer> bufferProvider, long offset, long length)
- totalSize
 
 protected long totalSize(Iterable<? extends ByteBuffer> sourceBuffers)
- 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
- isEmpty
 
 public boolean isEmpty(BlobStorePath directory)
 
 Specified by:
 
 isEmpty 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

Class BlobStoreConnector.Abstract<B>

Nested Class Summary

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

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Details

Constructor Details

Method Details