org.mule.modules.googlecloudstorage.services

Class ChannelService

java.lang.Object

org.mule.modules.googlecloudstorage.services.ChannelService

public class ChannelService
extends Object

Constructor Summary

Constructors

Constructor and Description
ChannelService(com.google.cloud.storage.Storage storageInstance)

Method Summary

Modifier and Type	Method and Description
void	closeReadChannel(com.google.cloud.ReadChannel readChannel)
void	closeWriteChannel(com.google.cloud.WriteChannel writeChannel)
com.google.cloud.ReadChannel	getReadChannel(com.google.cloud.storage.BlobId blobId, com.google.cloud.storage.Storage.BlobSourceOption... blobSourceOption)
InputStream	read(com.google.cloud.storage.BlobId blobId, com.google.cloud.storage.Storage.BlobSourceOption... blobSourceOption)
InputStream	read(String bucket, String blob, com.google.cloud.storage.Storage.BlobSourceOption... options)
InputStream	readDataFromReadChannel(com.google.cloud.ReadChannel readChannel)
com.google.cloud.ReadChannel	restoreReadChannel(com.google.cloud.RestorableState<com.google.cloud.ReadChannel> restorableState)
com.google.cloud.WriteChannel	restoreWriteChannel(com.google.cloud.RestorableState<com.google.cloud.WriteChannel> restorableState)
com.google.cloud.RestorableState<com.google.cloud.ReadChannel>	startReadRestorableState(com.google.cloud.ReadChannel readChannel)
com.google.cloud.RestorableState<com.google.cloud.WriteChannel>	startWriteRestorable(com.google.cloud.WriteChannel writeChannel)
com.google.cloud.WriteChannel	writeChannel(com.google.cloud.storage.BlobInfo blobInfo, com.google.cloud.storage.Storage.BlobWriteOption... options)
int	writeToChannel(com.google.cloud.WriteChannel writeChannel, ByteBuffer data)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelService

public ChannelService(com.google.cloud.storage.Storage storageInstance)

Method Detail

read

public InputStream read(String bucket,
                        String blob,
                        com.google.cloud.storage.Storage.BlobSourceOption... options)
                 throws GoogleStorageApiException

Throws:

GoogleStorageApiException

read

public InputStream read(com.google.cloud.storage.BlobId blobId,
                        com.google.cloud.storage.Storage.BlobSourceOption... blobSourceOption)
                 throws GoogleStorageApiException

Throws:

GoogleStorageApiException

getReadChannel

public com.google.cloud.ReadChannel getReadChannel(com.google.cloud.storage.BlobId blobId,
                                                   com.google.cloud.storage.Storage.BlobSourceOption... blobSourceOption)
                                            throws GoogleStorageApiException

Throws:

GoogleStorageApiException

startReadRestorableState

public com.google.cloud.RestorableState<com.google.cloud.ReadChannel> startReadRestorableState(com.google.cloud.ReadChannel readChannel)
                                                                                        throws GoogleStorageApiException

Throws:

GoogleStorageApiException

readDataFromReadChannel

public InputStream readDataFromReadChannel(com.google.cloud.ReadChannel readChannel)
                                    throws GoogleStorageApiException

Throws:

GoogleStorageApiException

closeReadChannel

public void closeReadChannel(com.google.cloud.ReadChannel readChannel)
                      throws GoogleStorageApiException

Throws:

GoogleStorageApiException

restoreReadChannel

public com.google.cloud.ReadChannel restoreReadChannel(com.google.cloud.RestorableState<com.google.cloud.ReadChannel> restorableState)
                                                throws GoogleStorageApiException

Throws:

GoogleStorageApiException

writeChannel

public com.google.cloud.WriteChannel writeChannel(com.google.cloud.storage.BlobInfo blobInfo,
                                                  com.google.cloud.storage.Storage.BlobWriteOption... options)
                                           throws GoogleStorageApiException

Throws:

GoogleStorageApiException

startWriteRestorable

public com.google.cloud.RestorableState<com.google.cloud.WriteChannel> startWriteRestorable(com.google.cloud.WriteChannel writeChannel)
                                                                                     throws GoogleStorageApiException

Throws:

GoogleStorageApiException

writeToChannel

public int writeToChannel(com.google.cloud.WriteChannel writeChannel,
                          ByteBuffer data)
                   throws GoogleStorageApiException,
                          IOException

Throws:

GoogleStorageApiException

IOException

closeWriteChannel

public void closeWriteChannel(com.google.cloud.WriteChannel writeChannel)
                       throws GoogleStorageApiException,
                              IOException

Throws:

GoogleStorageApiException

IOException

restoreWriteChannel

public com.google.cloud.WriteChannel restoreWriteChannel(com.google.cloud.RestorableState<com.google.cloud.WriteChannel> restorableState)
                                                  throws GoogleStorageApiException

Throws:

GoogleStorageApiException