ump_intake.blobs

module ump-intake

Content-addressed blob writes and reads through core’s POST /v1/blobs (the GCS stand-in), so every write is principal-checked and emits blob.stored. The client is any object with upload_blob and get_blob coroutines (ump_sdk.AsyncCoreClient).

Classes

BlobClient

class

class BlobClient(Protocol)

Methods and properties (2)

upload_blob method

async def upload_blob(self, data: bytes | str, *, content_type: str = ...) -> Any

get_blob method

async def get_blob(self, ref: str) -> Any

Source: packages/ump-intake/src/ump_intake/blobs.py, line 13

Functions

put_blob

function

async def put_blob(
    c: Any,
    data: bytes,
    content_type: str = 'application/octet-stream',
) -> tuple[str, str]

Write-once content-addressed file. Returns (hex, blob://sha256/<hex>).

Source: packages/ump-intake/src/ump_intake/blobs.py, line 19

read_blob

function

async def read_blob(c: Any, hexd: str) -> bytes

Source: packages/ump-intake/src/ump_intake/blobs.py, line 25