Gamma is a distributed video processing platform (a Mux-like) designed to handle video ingestion, processing, and delivery.
- Docker & Docker Compose
- Go 1.23+
- Node.js & pnpm (for the dashboard)
-
Start Infrastructure (PostgreSQL, NATS, MinIO):
make docker-up
-
Run Migrations:
make migrate-up
-
Run Services (in separate terminals):
make run-api make run-worker
-
Start Dashboard:
make dashboard-start
Access the dashboard at
http://localhost:4200. -
Login:
- Username:
admin - Password:
admin
- Username:
Gamma supports multi-tenancy through Realms. Each realm is an isolated environment with its own uploads and assets. A default realm is created automatically on first run.
- Create, list, and delete realms from the dashboard
- Switch between realms using the dropdown in the navbar
- All uploads and assets are scoped to a realm
flowchart TB
subgraph Client ["Client Side"]
direction TB
User["π€ User"] -- Uses --> Dashboard["π» Dashboard<br>(Angular)"]
end
Dashboard -- "HTTP / WebSocket" --> API["βοΈ API Service<br>(Go)"]
API -- "SQL" --> DB[("π PostgreSQL<br>(Database)")]
Dashboard -- "Direct Upload" --> MinIO[("ποΈ MinIO<br>(S3 Storage)")]
MinIO -. "Events" .-> NATS["π¨ NATS<br>(JetStream)"]
subgraph WorkerPool ["β‘ Scalable Worker Pool"]
direction LR
Worker["π οΈ Worker 1<br>(Go)"]
Worker2["π οΈ Worker 2..N<br>(Go)"]
end
NATS -- "Jobs" --> Worker
NATS -.- Worker2
Worker -- "Process / Delete" --> MinIO
Worker -- "Update Status" --> DB
Worker -- "Events" --> NATS
NATS -- "Notify" --> API
User:::user
Dashboard:::angular
API:::go
Worker:::go
Worker2:::go
MinIO:::storage
NATS:::messaging
DB:::db
style WorkerPool fill:transparent,stroke:#00bcd4,stroke-width:2px,stroke-dasharray: 5 5,color:#fff
style Client fill:transparent,stroke:#90a4ae,stroke-width:2px,stroke-dasharray: 5 5,color:#fff
classDef user fill:#37474f,stroke:#90a4ae,stroke-width:2px,color:#fff
classDef angular fill:#880e4f,stroke:#f50057,stroke-width:2px,color:#fff
classDef go fill:#006064,stroke:#00bcd4,stroke-width:2px,color:#fff
classDef storage fill:#b71c1c,stroke:#ff5252,stroke-width:2px,color:#fff
classDef messaging fill:#1b5e20,stroke:#66bb6a,stroke-width:2px,color:#fff
classDef db fill:#1a237e,stroke:#7986cb,stroke-width:2px,color:#fff
erDiagram
realms {
UUID id PK
VARCHAR name UK
realm_status status
TIMESTAMPTZ created_at
TIMESTAMPTZ deleted_at
}
uploads {
UUID id PK
UUID realm_id FK
TEXT title
TEXT s3_key
upload_status status
TIMESTAMPTZ created_at
TIMESTAMPTZ updated_at
TIMESTAMPTZ deleted_at
}
assets {
UUID id PK
UUID upload_id FK
UUID realm_id FK
TEXT hls_root
asset_status status
TIMESTAMPTZ created_at
TIMESTAMPTZ updated_at
TIMESTAMPTZ deleted_at
}
realms ||--o{ uploads : "has many"
realms ||--o{ assets : "has many"
uploads ||--o| assets : "has one"
Enums:
realm_status:active,deletedupload_status:pending,uploaded,processing,ready,failed,deletedasset_status:processing,ready,failed,deleted
sequenceDiagram
actor User
participant Dash as Dashboard
participant API
participant DB as PostgreSQL
participant S3 as MinIO
participant NATS
participant Worker
User->>Dash: Select Video File
Dash->>API: POST /{realm}/uploads
API->>S3: Generate Presigned URL
API->>DB: Create Upload (pending)
API-->>Dash: Return UploadID, URL
Dash->>S3: PUT File (Direct Upload)
S3->>NATS: Event: s3:ObjectCreated
NATS->>Worker: Consume Upload Event
Worker->>S3: Download Original
Worker->>Worker: Transcode (FFmpeg)
Worker->>S3: Upload HLS Segments
Worker->>DB: Create Asset (ready)
Worker->>DB: Update Upload (ready)
Worker->>NATS: Event: asset_processed
NATS->>API: Consume Event
API-->>Dash: WebSocket: asset_processed
Dash->>User: Update UI (Ready)
sequenceDiagram
actor User
participant Dash as Dashboard
participant API
participant DB as PostgreSQL
participant NATS
participant Worker
participant S3 as MinIO
User->>Dash: Click Delete
Dash->>API: DELETE /{realm}/assets/{id}
API->>DB: Soft Delete Asset
API->>DB: Soft Delete Upload
API->>NATS: Event: delete_asset
API-->>Dash: 204 No Content
Dash->>User: Remove from List
NATS->>Worker: Consume Delete Event
Worker->>S3: Delete Original File
Worker->>S3: Delete HLS Folder
Gamma is built using a microservices architecture:
- API (
cmd/api): Handles HTTP requests, file uploads, and serves data to the frontend. - Worker (
cmd/worker): Consumes jobs from NATS to process videos (transcoding, etc.) asynchronously.
- Backend: Go
- Frontend: Angular
- Database: PostgreSQL
- Messaging: NATS
- Storage: S3-compatible object storage (MinIO for local development)
- Basic video ingestion and upload flow
- Asynchronous worker processing
- Basic Dashboard UI
- Multi-quality transcoding (ABR)
- Multi-tenancy with Realms
- Authentication (login/logout)
See ISSUES.md for the full roadmap and todo list.