Graviton
0.0.0+1-c6dfdc46
API
Generated with
Graviton/graviton.runtime/graviton.runtime.stores/CasBlobStore/IngestConfig

IngestConfig

graviton.runtime.stores.CasBlobStore.IngestConfig
final case class IngestConfig(ioChunkBytes: UploadChunkSize = ..., inputBufferChunks: Int = ..., blockBufferBlocks: Int = ...)

Byte-level queue limits for upload ingest.

Attributes

Source
CasBlobStore.scala
Graph
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all

Members list

Value members

Concrete methods

def maximumPipelineBytes(chunker: Chunker, persistence: BlockPersistenceConfig): Long

Conservative live-byte ceiling for Graviton's queues and in-flight block writes. This excludes one caller-owned input chunk, the chunker's documented working set, and backend-local buffers.

Conservative live-byte ceiling for Graviton's queues and in-flight block writes. This excludes one caller-owned input chunk, the chunker's documented working set, and backend-local buffers.

Attributes

Source
CasBlobStore.scala
def maximumPipelineFootprint(chunker: Chunker, persistence: BlockPersistenceConfig, blockStore: BlockStore): Either[Error, TransferFootprint]

Every Graviton-owned live allocation, including backend-declared replay, replica, or erasure buffers. The composed total is reserved exactly once.

Every Graviton-owned live allocation, including backend-declared replay, replica, or erasure buffers. The composed total is reserved exactly once.

Attributes

Source
CasBlobStore.scala
def maximumPipelineFootprint(chunker: Chunker, persistence: BlockPersistenceConfig, blockStore: BlockStore, program: IngestProgram, scanWindowRefs: Int): Either[Error, TransferFootprint]

Attributes

Source
CasBlobStore.scala
def maximumQueuedBytes(chunker: Chunker): Long

Bytes retained by the two queues, excluding one caller-owned upstream chunk, the chunker's documented working set, and backend-local buffers.

Bytes retained by the two queues, excluding one caller-owned upstream chunk, the chunker's documented working set, and backend-local buffers.

Attributes

Source
CasBlobStore.scala

Inherited methods

def productElementNames: Iterator[String]

An iterator over the names of all the elements of this product.

An iterator over the names of all the elements of this product.

Attributes

Inherited from:
Product
Source
Product.scala
def productIterator: Iterator[Any]

An iterator over all the elements of this product.

An iterator over all the elements of this product.

Attributes

Returns

in the default implementation, an Iterator[Any]

Inherited from:
Product
Source
Product.scala
Generated with