API Reference Forge v#0.1.1

A domain-agnostic sample factory library for generating, transforming, and computing measurements on arbitrary samples.

Plug router exposing Forge /v1 endpoints for SampleIR and DatasetIR.

Boots the Forge /v1 Plug router via Plug.Cowboy.

Repo-backed storage for the Forge /v1 IR API.

Behaviour for Anvil integration - publishing samples to Anvil for labeling.

Direct Elixir adapter for AnvilBridge - in-process integration.

HTTP adapter for AnvilBridge - REST API integration.

Mock adapter for AnvilBridge used in testing.

Behaviour for artifact storage backends.

Local filesystem adapter for artifact storage.

S3 adapter for artifact storage (stub implementation).

Classifies errors as retriable or non-retriable based on retry policy.

Pipeline manifest for reproducibility and lineage tracking.

Deterministic hashing for pipeline configurations.

Behaviour for computing measurements on samples.

Behaviour for external compute backends (ALTAR, Snakepit, etc.).

ALTAR (Python Celery) integration for topological data analysis.

Snakepit (LLM worker pool) integration for semantic measurements.

Orchestrates measurement computation with support for

DSL for defining sample processing pipelines.

Pipeline configuration structure.

Ecto repository for Forge persistence layer.

Retry policy configuration for stage execution.

GenServer for executing pipelines.

Streaming runner with backpressure and async stage support.

Core data structure representing a sample in the Forge pipeline.

Ecto schema for artifact metadata.

Ecto schema for measurement results.

Ecto schema for pipeline definitions.

Ecto schema for storing pipeline run manifests.

Ecto schema for sample records.

Ecto schema for stage execution history.

Behaviour for sample sources.

Generator source that creates samples using a function.

Static source that provides a pre-defined list of samples.

Behaviour for pipeline stages.

Executes stages with retry logic and error handling.

Behaviour for sample storage backends.

In-memory ETS-based storage backend.

PostgreSQL storage adapter for Forge samples.

Telemetry instrumentation for Forge pipelines.

Telemetry metrics definitions for Forge pipelines.

OpenTelemetry integration for Forge (optional).