PgLoBinaryStore

binny.pglo.PgLoBinaryStore
See thePgLoBinaryStore companion object
final class PgLoBinaryStore[F[_]](val config: PgLoConfig, logger: Logger[F], ds: DataSource)(implicit evidence$1: Sync[F]) extends JdbcBinaryStore[F]

Attributes

Companion:
object
Graph
Supertypes
trait JdbcBinaryStore[F]
trait BinaryStore[F]
class Object
trait Matchable
class Any

Members list

Concise view

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.

Attributes

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

Deletes all data associated to the given id.

Deletes all data associated to the given id.

Attributes

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.

Attributes

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.

Attributes

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.

Attributes

def insert: (F, Byte) => BinaryId

Insert the given bytes creating a new id.

Insert the given bytes creating a new id.

Attributes

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.

Attributes

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.

Attributes

Concrete fields