🥮 mooncakes.io

moonbit-ocean-qc

Composable, explainable, and traceable quality control for ocean observations.

ocean
quality-control
provenance
observations
moon add lwq443/moonbit-ocean-qc@0.2.0
Download zip
Author
Version
0.2.0
License
Apache-2.0
Repository
Last updated
5 hours ago
Downloads
2
README

#MoonBit Ocean QC

The repository provides a MoonBit-native quality-control model for ocean observations. A finding carries its rule, flag, severity, original value, reason, processing time, and provenance.

#Quick start

moon check --deny-warn
moon test --deny-warn
moon run cmd/main

The executable example is kept in cmd/main/main.mbt; the public package API is documented in the generated interface file.

#Package map

  • The root package owns observations, rules, findings, summaries, and provenance.
  • profile owns variable aliases, canonical units, physical envelopes, and validation.
  • stats owns online descriptive statistics and distribution helpers.
  • stream owns bounded batch processing.
  • report owns deterministic text, CSV, and JSON-lines output.

#Development

Run moon fmt, moon check --deny-warn, moon info, and moon test --deny-warn before submitting changes. The CI workflow repeats these checks on the default and native targets.

#License

Apache-2.0.

#
Finding

source
pub(all) struct Finding {
  observation_id : String
  rule : RuleKind
  flag : QualityFlag
  severity : Severity
  reason : String
  original_value : Double?
  processed_at : Int
  provenance : Provenance
} derive(
Debug)

#
Observation

source
pub(all) struct Observation {
  id : String
  timestamp : Int
  latitude : Double
  longitude : Double
  variable : String
  value : Double?
  unit : String
  platform : String
} derive(
Debug)

#
Observation::new

source
fn Observation::new(id~ : String, timestamp~ : Int, latitude~ : Double, longitude~ : Double, variable~ : String, value~ : Double?, unit~ : String, platform~ : String) -> Observation

#
Provenance

source
pub(all) struct Provenance {
  source : String
  dataset : String
  observed_at : Int
  processor : String
  version : String
} derive(
Debug)

#
QcSummary

source
pub(all) struct QcSummary {
  total : Int
  good : Int
  missing : Int
  suspect : Int
  bad : Int
  findings : Array[Finding]
} derive(
Debug)

#
QualityFlag

source
pub(all) enum QualityFlag {
  Good
  Missing
  Suspect
  Bad
} derive(Eq, 
Debug)

#
RuleConfig

source
pub(all) struct RuleConfig {
  range_min : Double?
  range_max : Double?
  max_delta : Double?
  max_interval : Int?
  max_speed : Double?
  climate_min : Double?
  climate_max : Double?
  duplicate_window : Int
  processing_time : Int
} derive(
Debug)

#
RuleConfig::default

source
fn RuleConfig::default() -> RuleConfig

#
RuleKind

source
pub(all) enum RuleKind {
  Range
  Missing
  Spike
  Duplicate
  Interval
  SpatialJump
  ClimateAnomaly
  Multivariate
} derive(Eq, 
Debug)

#
Severity

source
pub(all) enum Severity {
  Info
  Warning
  Error
} derive(Eq, 
Debug)

#
inspect

source
fn inspect(observations : Array[Observation], config : RuleConfig) -> QcSummary

#
render_report

source
fn render_report(summary : QcSummary) -> String

Source Files

Powered by MoonBit

Site sourceReport issuePackagesBuild queueSkillsStatistics

© 2026 mooncakes.io