PgLoBinaryStore

final class PgLoBinaryStore[F[_]](val config: PgLoConfig, logger: Logger[F], ds: DataSource)(implicit evidence$1: Sync[F]) extends JdbcBinaryStore[F]
Companion:
object
trait JdbcBinaryStore[F]
trait BinaryStore[F]
class Object
trait Matchable
class Any

Value members

Concrete methods

def computeAttr(id: BinaryId, hint: Hint): ComputeAttr[F]

Retrieves a selected set of attributes of a binary.

Retrieves a selected set of attributes of a binary.

def delete(id: BinaryId): F[Unit]

Deletes all data associated to the given id.

Deletes all data associated to the given id.

def exists(id: BinaryId): F[Boolean]

Check if a file exists. Same as findBinary().isDefined, but usually more efficiently implemented.

Check if a file exists. Same as findBinary().isDefined, but usually more efficiently implemented.

def findBinary(id: BinaryId, range: ByteRange): OptionT[F, Binary[F]]

Find the binary by its id. The byte stream is constructed to close resources to the database after loading a chunk. This is for safety, since database timeouts can occur if the stream "blocks". The findBinaryStateful is a variant that uses a single connection for the entire stream.

Find the binary by its id. The byte stream is constructed to close resources to the database after loading a chunk. This is for safety, since database timeouts can occur if the stream "blocks". The findBinaryStateful is a variant that uses a single connection for the entire stream.

def findBinaryStateful(id: BinaryId, range: ByteRange): OptionT[F, Binary[F]]

Finds the binary by its id and returns the bytes as a stream that uses a single connection to the database. The connection is closed when the stream is terminated.

Finds the binary by its id and returns the bytes as a stream that uses a single connection to the database. The connection is closed when the stream is terminated.

def insert: (F, Byte) => BinaryId

Insert the given bytes creating a new id.

Insert the given bytes creating a new id.

def insertWith(id: BinaryId): (F, Byte) => Nothing

Insert the given bytes to the given id. If some file already exists by this id, the behavior depends on the implementation.

Insert the given bytes to the given id. If some file already exists by this id, the behavior depends on the implementation.

def listIds(prefix: Option[String], chunkSize: Int): Stream[F, BinaryId]

Returns a set of ids currently available in this store.

Returns a set of ids currently available in this store.

Concrete fields