dasomel — OSS Workbench

Project Overview

Beluga Manager is the unified control plane and management console for the Beluga Data Platform.

The project does not try to reimplement Kafka, Flink, Iceberg, Trino, or Airflow UIs. Each upstream system remains authoritative for its own resources. Beluga Manager adds value by answering questions that cross those service boundaries.

Examples:

Which Kafka Topic and Flink Job belong to the same Pipeline?
Which Iceberg table represents a Data Asset and how can it be queried?
Which downstream resources are affected by a failed job?
Which platform services are healthy, stale, degraded, or unavailable?

The product focus is integration context, not UI duplication.

Domain Model

Pipeline

Source / CDC
    ↓
Kafka Topic
    ↓
Flink Job
    ↓
Iceberg Table
    ↓
Trino / Query

A Pipeline correlates resources across the data platform into one operational unit.

Data Asset

Provides catalog, schema, table, columns, partitions, location, and query context while keeping Iceberg authoritative for lakehouse metadata.

Service

Represents platform capability rather than a simple installation list: Streaming, Processing, Lakehouse, Query, Orchestration, BI, Storage, and Observability.

Operations

Combines health, events, logs, resources, and dependencies for cross-service investigation.

Integration Architecture

OSS API
   ↓
Integration Adapter
   ↓
Discovery / Correlation
   ↓
Beluga Domain
   ↓
Unified API
   ↓
Manager UI

This isolates OSS API versions and implementation differences from the frontend.

State Model

Beluga Manager distinguishes:

State	Meaning
Authoritative state	State owned by the upstream OSS
Short-lived cache	Performance cache
Correlation index	Cross-service relationship index
Beluga-owned metadata	Explicit platform metadata and mappings

Uncertain relationships should not be presented as authoritative facts.

MVP Direction

The repository is currently early development / architecture-first. The planned order is:

API Contract
    ↓
Unified Service API
    ↓
Discovery / Correlation
    ↓
Kafka → Flink → Iceberg → Trino
    ↓
Data Asset / Query / Operations

Initial scope focuses on read-first capabilities: service discovery, pipeline topology, health/status, degraded/stale states, resource/event/log drill-down, and English/Korean foundations. Broad destructive management actions remain out of scope for the first slice.

API Direction

GET /api/v1/services
GET /api/v1/services/{id}
GET /api/v1/pipelines
GET /api/v1/pipelines/{id}
GET /api/v1/data-assets
GET /api/v1/health
GET /api/v1/events

The frontend should consume Beluga Domain APIs rather than calling every upstream OSS API directly.

Internationalization

The project is designed around en-US and ko-KR, browser detection, manual selection, persistent preferences, and locale-neutral APIs. Real resource identifiers such as Topic names, tables, jobs, and namespaces are never translated.

Current Status

Early development. Beluga Manager is being established as a reference implementation for the problem of cross-OSS data-platform context rather than as a finished production management console.

Getting Started

git clone https://github.com/dasomel/beluga-manager.git
cd beluga-manager
pnpm install
pnpm dev

Documentation Index

Topic	Document	Purpose
Overview	Manager Overview	Problem, domains, MVP
Architecture	Control Plane Architecture	Adapters, correlation, unified API
Development	Development Guide	Project structure and local workflow
Operations	Operations	Deployment and environment conventions

Project Relationship

Beluga
  ├── Kafka
  ├── Flink
  ├── Iceberg
  ├── Trino
  └── Airflow
          ↓
    Beluga Manager
          ↓
 Pipeline / Data Asset / Service / Operations