object Ftp extends FtpApi[FTPClient] with FtpSourceParams
- Source
- FtpApi.scala
- Alphabetic
- By Inheritance
- Ftp
- FtpSourceParams
- FtpDefaultSettings
- FtpSource
- FtpSourceFactory
- FtpApi
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
type
S = FtpSettings
- Definition Classes
- FtpSourceParams → FtpSourceFactory
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
val
DefaultChunkSize: Int(8192)
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
final
val
FtpBrowserSourceName: String("FtpBrowserSource")
- Attributes
- protected
- Definition Classes
- FtpSource
-
final
val
FtpDirectorySource: String("FtpDirectorySource")
- Attributes
- protected
- Definition Classes
- FtpSource
-
final
val
FtpIOSinkName: String("FtpIOSink")
- Attributes
- protected
- Definition Classes
- FtpSource
-
final
val
FtpIOSourceName: String("FtpIOSource")
- Attributes
- protected
- Definition Classes
- FtpSource
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
def
createBrowserGraph(_basePath: String, _connectionSettings: S, _branchSelector: (FtpFile) ⇒ Boolean, _emitTraversedDirectories: Boolean)(implicit _ftpLike: FtpLike[FTPClient, S]): FtpBrowserGraphStage[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
def
createBrowserGraph(_basePath: String, _connectionSettings: S, _branchSelector: (FtpFile) ⇒ Boolean)(implicit _ftpLike: FtpLike[FTPClient, S]): FtpBrowserGraphStage[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
def
createIOSink(_path: String, _connectionSettings: S, _append: Boolean)(implicit _ftpLike: FtpLike[FTPClient, S]): FtpIOSinkStage[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
def
createIOSource(_path: String, _connectionSettings: S, _chunkSize: Int, _offset: Long)(implicit _ftpLike: FtpLike[FTPClient, S]): FtpIOSourceStage[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
def
createIOSource(_path: String, _connectionSettings: S, _chunkSize: Int)(implicit _ftpLike: FtpLike[FTPClient, S]): FtpIOSourceStage[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
def
createMkdirGraph(baseDirectoryPath: String, dirName: String, currentConnectionSettings: S)(implicit _ftpLike: FtpLike[FTPClient, S]): FtpDirectoryOperationsGraphStage[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
def
createMoveSink(_destinationPath: (FtpFile) ⇒ String, _connectionSettings: S)(implicit _ftpLike: FtpLike[FTPClient, S]): GraphStageWithMaterializedValue[SinkShape[FtpFile], Future[IOResult]] with FtpMoveSink[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
def
createRemoveSink(_connectionSettings: S)(implicit _ftpLike: FtpLike[FTPClient, S]): GraphStageWithMaterializedValue[SinkShape[FtpFile], Future[IOResult]] with FtpRemoveSink[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceFactory
-
def
defaultSettings(hostname: String, username: Option[String], password: Option[String]): FtpSettings
- Attributes
- protected
- Definition Classes
- FtpDefaultSettings
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
fromPath(path: String, connectionSettings: S, chunkSize: Int, offset: Long): Source[ByteString, Future[IOResult]]
Scala API: creates a Source of ByteString from some file path.
Scala API: creates a Source of ByteString from some file path.
- path
the file path
- connectionSettings
connection setting
- chunkSize
the size of transmitted ByteString chunks
- offset
the offset into the remote file at which to start the file transfer
- returns
A Source of ByteString that materializes to a Future of IOResult
- Definition Classes
- FtpApi
-
def
fromPath(path: String, connectionSettings: S, chunkSize: Int = DefaultChunkSize): Source[ByteString, Future[IOResult]]
Scala API: creates a Source of ByteString from some file path.
Scala API: creates a Source of ByteString from some file path.
- path
the file path
- connectionSettings
connection settings
- chunkSize
the size of transmitted ByteString chunks
- returns
A Source of ByteString that materializes to a Future of IOResult
- Definition Classes
- FtpApi
-
def
fromPath(host: String, username: String, password: String, path: String): Source[ByteString, Future[IOResult]]
Scala API: creates a Source of ByteString from some file path.
Scala API: creates a Source of ByteString from some file path.
- host
FTP, FTPs or SFTP host
- username
username
- password
password
- path
the file path
- returns
A Source of ByteString that materializes to a Future of IOResult
- Definition Classes
- FtpApi
-
def
fromPath(host: String, path: String): Source[ByteString, Future[IOResult]]
Scala API: creates a Source of ByteString from some file path.
Scala API: creates a Source of ByteString from some file path.
- host
FTP, FTPs or SFTP host
- path
the file path
- returns
A Source of ByteString that materializes to a Future of IOResult
- Definition Classes
- FtpApi
-
val
ftpBrowserSourceName: String
- Attributes
- protected
- Definition Classes
- FtpSource → FtpSourceFactory
-
val
ftpClient: () ⇒ FTPClient
- Attributes
- protected
- Definition Classes
- FtpSource → FtpSourceFactory
-
val
ftpDirectorySourceName: String
- Attributes
- protected
- Definition Classes
- FtpSource → FtpSourceFactory
-
val
ftpIOSinkName: String
- Attributes
- protected
- Definition Classes
- FtpSource → FtpSourceFactory
-
val
ftpIOSourceName: String
- Attributes
- protected
- Definition Classes
- FtpSource → FtpSourceFactory
-
val
ftpLike: FtpLike[FTPClient, S]
- Attributes
- protected[this]
- Definition Classes
- FtpSourceParams
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
ls(basePath: String, connectionSettings: S, branchSelector: (FtpFile) ⇒ Boolean, emitTraversedDirectories: Boolean): Source[FtpFile, NotUsed]
Scala API: creates a Source of FtpFiles from a base path.
- basePath
Base path from which traverse the remote file server
- connectionSettings
connection settings
- branchSelector
a function for pruning the tree. Takes a remote folder and return true if you want to enter that remote folder. Default behaviour is fully recursive which is equivalent with calling this function with [ls(basePath,connectionSettings,f=>true)]. Calling [ls(basePath,connectionSettings,f=>false)] will emit only the files and folder in non-recursive fashion
- emitTraversedDirectories
whether to include entered directories in the stream
- returns
- Definition Classes
- FtpApi
-
def
ls(basePath: String, connectionSettings: S, branchSelector: (FtpFile) ⇒ Boolean): Source[FtpFile, NotUsed]
Scala API: creates a Source of FtpFiles from a base path.
- basePath
Base path from which traverse the remote file server
- connectionSettings
connection settings
- branchSelector
a function for pruning the tree. Takes a remote folder and return true if you want to enter that remote folder. Default behaviour is fully recursive which is equivalent with calling this function with [ls(basePath,connectionSettings,f=>true)]. Calling [ls(basePath,connectionSettings,f=>false)] will emit only the files and folder in non-recursive fashion
- returns
- Definition Classes
- FtpApi
- def ls(basePath: String, connectionSettings: S): Source[FtpFile, NotUsed]
- def ls(host: String, username: String, password: String, basePath: String): Source[FtpFile, NotUsed]
-
def
ls(host: String, username: String, password: String): Source[FtpFile, NotUsed]
Scala API: creates a Source of FtpFiles from the remote user
root
directory. - def ls(host: String, basePath: String): Source[FtpFile, NotUsed]
-
def
ls(host: String): Source[FtpFile, NotUsed]
Scala API: creates a Source of FtpFiles from the remote user
root
directory. -
def
mkdir(basePath: String, name: String, connectionSettings: S): Source[Done, NotUsed]
Scala API for creating a directory in a given path
-
def
mkdirAsync(basePath: String, name: String, connectionSettings: S)(implicit mat: Materializer): Future[Done]
Scala API for creating a directory in a given path
-
def
move(destinationPath: (FtpFile) ⇒ String, connectionSettings: S): Sink[FtpFile, Future[IOResult]]
Scala API: creates a Sink of a FtpFile that moves a file to some file path.
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def remove(connectionSettings: S): Sink[FtpFile, Future[IOResult]]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toPath(path: String, connectionSettings: S, append: Boolean = false): Sink[ByteString, Future[IOResult]]
Scala API: creates a Sink of ByteString to some file path.
Scala API: creates a Sink of ByteString to some file path.
- path
the file path
- connectionSettings
connection settings
- append
append data if a file already exists, overwrite the file if not
- returns
A Sink of ByteString that materializes to a Future of IOResult
- Definition Classes
- FtpApi
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )