sftp/blobstore.sftp/SftpStore

SftpStore

class SftpStore[F[_]] extends PathStore[F, SftpFile]
Value Params
blocker

cats-effect blocker.

connectTimeoutMillis

override for channel connect timeout.

queue

queue to hold channels to be reused.

semaphore

optional semaphore to limit the number of concurrently open channels.

session

connected jsch Session.

Companion
object
class PathStore[F, SftpFile]
class Object
trait Matchable
class Any

Value members

Concrete methods

def _stat[A](path: Path[A], channel: ChannelSftp): F[Option[Path[SftpFile]]]
def closeChannel(ch: ChannelSftp): F[Unit]
override
def copy[A, B](src: Path[A], dst: Path[B]): F[Unit]
Definition Classes
PathStore
override
def get[A](path: Path[A], chunkSize: Int): Stream[F, Byte]
Definition Classes
PathStore
override
def getContents[A](path: Path[A], chunkSize: Int): F[String]
Definition Classes
PathStore
override
def lift: Store[F, SftpFile]
Definition Classes
PathStore
override
def lift(g: Plain => Validated[Throwable, Plain]): Store[F, SftpFile]
Definition Classes
PathStore
override
def list[A](path: Path[A], recursive: Boolean): Stream[F, Path[SftpFile]]
Definition Classes
PathStore
override
def move[A, B](src: Path[A], dst: Path[B]): F[Unit]
Definition Classes
PathStore
override
def put[A](path: Path[A], overwrite: Boolean, size: Option[Long]): (F, Byte) => Unit
Definition Classes
PathStore
override
def putRotate[A](computePath: F[Path[A]], limit: Long): (F, Byte) => Unit
Definition Classes
PathStore
override
def remove[A](path: Path[A], recursive: Boolean): F[Unit]
Definition Classes
PathStore
override
def stat[A](path: Path[A]): F[Option[Path[SftpFile]]]
Definition Classes
PathStore
override
def transferTo[B, P, A](dstStore: Store[F, B], srcPath: Path[P], dstUrl: Url[A])(implicit ev: B <:< FsObject): F[Int]
Definition Classes
PathStore

Inherited methods

def put[A](contents: String, path: Path[A], overwrite: Boolean): Stream[F, Unit]
Inherited from
PathStore