PgLoBinaryStore

final class PgLoBinaryStore[F[_]](val config: PgLoConfig, logger: Logger[F], ds: DataSource, attrStore: BinaryAttributeStore[F])(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): OptionT[F, BinaryAttributes]
def delete(id: BinaryId): F[Unit]
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(hint: Hint): (F, Byte) => BinaryId
def insertWith(id: BinaryId, hint: Hint): (F, Byte) => Nothing
def listIds(prefix: Option[String], chunkSize: Int): Stream[F, BinaryId]

Concrete fields