pub suberror ParseError {
  Invalid(Int, String)
}

pub struct Aggregation {
  // private fields
}

pub struct AggregationReport {
  schema_version : String
  scope : String
  deduplication : String
  ordering : String
  changed_prefixes : Int
  affected_peers : Int
  change_notices : Int64
  change_types : Map[String, Int64]
  top_prefixes : Array[PrefixRanking]
} derive(ToJson)

pub struct Aggregator {
  asn : UInt
  address : String
} derive(Eq, Hash, ToJson, 
@moonbitlang/core/json.FromJson
FromJson)

pub struct AggregatorDiff {
  before : Aggregator?
  after : Aggregator?
}

pub struct AnalysisQuery {
  side : String?
  origin_asns : Array[UInt]?
  path_asns : Array[UInt]?
  communities : Array[UInt]?
  origin_unknown : Bool?
  prefix : String?
  prefix_mode : String?
  peer_asn : UInt?
  outbound : Bool?
  path_id : UInt?
  collector : String?
  view : String?
  from_us : UInt64?
  to_us : UInt64?
  kind : String?
} derive(ToJson, 
@moonbitlang/core/json.FromJson
FromJson)

pub struct Analyzer {
  // private fields
}

pub struct AsSegment {
  kind : Int
  asns : Array[UInt]
} derive(Eq, Hash, ToJson, 
@moonbitlang/core/json.FromJson
FromJson)

pub struct AtomicAggregateDiff {
  before : Bool
  after : Bool
} derive(ToJson)

pub struct Attributes {
  origin : Int?
  path : Array[AsSegment]
  wire_path : Array[AsSegment]
  as4_path : Array[AsSegment]
  next_hop : String?
  med : UInt?
  local_pref : UInt?
  atomic_aggregate : Bool
  aggregator : Aggregator?
  wire_aggregator : Aggregator?
  as4_aggregator : Aggregator?
  raw_attributes : Array[RawAttribute]
  communities : Array[UInt]
  large_communities : Array[(UInt, UInt, UInt)]
  other : Array[RawAttribute]
} derive(Eq, Hash, ToJson)

pub struct Batch {
  header : Header
  microseconds : Int?
  events : Array[RouteEvent]
  states : Array[StateChange]
  skipped : Bool
  ignored_families : Int
  message_type : Int?
  diagnostics : Array[Diagnostic]
} derive(ToJson)

pub struct BgpRecord {
  message_type : Int
  events : Array[RouteEvent]
  states : Array[StateChange]
  ignored_families : Int
  ignored : Array[(Int, Int)]
}

pub struct Change {
  schema_version : String
  timestamp : UInt
  microseconds : Int?
  prefix : String
  path_id : UInt?
  peer_asn : UInt
  peer_ip : String
  outbound : Bool
  kind : String
  source : Source?
  before : RouteSnapshot?
  after : RouteSnapshot
  diff : RouteDiff
  churn_count : Int?
  correlation_key : String?
} derive(ToJson)

pub struct CommunityDiff {
  before : Array[UInt]
  after : Array[UInt]
  added : Array[UInt]
  removed : Array[UInt]
} derive(ToJson)

pub struct ComparisonWindow {
  from_us : UInt64
  to_us : UInt64
} derive(ToJson, 
@moonbitlang/core/json.FromJson
FromJson)

pub struct Decoder {
  // private fields
}

pub struct Diagnostic {
  kind : String
  mrt_type : Int
  subtype : Int
  afi : Int?
  safi : Int?
  source : Source?
} derive(ToJson)

pub struct FocusRule {
  prefix : String
  expected_origins : Array[UInt]?
  allowed_more_specifics : Array[String]?
} derive(ToJson, 
@moonbitlang/core/json.FromJson
FromJson)

pub struct Frame {
  header : Header
  microseconds : Int?
  payload : Bytes
} derive(Eq)

pub struct Header {
  timestamp : UInt
  kind : Int
  subtype : Int
  length : Int
} derive(Eq, ToJson)

pub struct HopDiff {
  before : String?
  after : String?
}

pub struct Investigation {
  // private fields
}

pub struct InvestigationEvent {
  id : String
  time_us : UInt64
  prefix : String
  peer : String
  peer_asn : UInt
  peer_ip : String
  outbound : Bool
  path_id : UInt?
  source : Source?
  kind : String
  accepted : Bool
  changes_state : Bool
  before : RouteSnapshot?
  after : RouteSnapshot?
  changes : Array[Change]
  selected : Bool
  before_path : Json?
  after_path : Json?
} derive(ToJson)

pub struct InvestigationGap {
  from_us : UInt64
  to_us : UInt64
  collector : String?
  view : String?
} derive(ToJson, 
@moonbitlang/core/json.FromJson
FromJson)

pub struct InvestigationInterval {
  key : String
  prefix : String
  peer : String
  peer_asn : UInt
  peer_ip : String
  outbound : Bool
  collector : String?
  view : String?
  path_id : UInt?
  from_us : UInt64
  to_us : UInt64
  state : String
  duration_us : UInt64?
  left_censored : Bool
  right_censored : Bool
  start_source : Source?
  end_source : Source?
  origin_as : UInt?
  path_length : Int?
} derive(ToJson)

pub struct InvestigationRules {
  schema_version : String
  version : String
  from_us : UInt64
  to_us : UInt64
  bucket_us : UInt64?
  incident_us : UInt64?
  capacity : Int?
  max_bytes : Int?
  continuous : Bool?
  gaps : Array[InvestigationGap]?
  focus : Array[FocusRule]?
  query : AnalysisQuery?
  comparison : Array[ComparisonWindow]?
  sequence_prefix : String?
  scope_prefixes : Array[String]?
  scope_peer_asns : Array[UInt]?
} derive(ToJson, 
@moonbitlang/core/json.FromJson
FromJson)

pub struct LargeCommunityDiff {
  before : Array[(UInt, UInt, UInt)]
  after : Array[(UInt, UInt, UInt)]
  added : Array[(UInt, UInt, UInt)]
  removed : Array[(UInt, UInt, UInt)]
} derive(ToJson)

pub struct ObservationGap {
  from_time : UInt
  from_micros : Int
  to_time : UInt
  to_micros : Int
} derive(ToJson)

pub struct OriginDiff {
  before : UInt?
  after : UInt?
}

pub struct PartitionedBatch {
  header : Header
  microseconds : Int?
  skipped : Bool
  ignored_families : Int
  diagnostics : Array[Diagnostic]
  route_events : Int
  state_events : Int
  peer_table : Bool
  parts : Array[PeerRecord]
} derive(ToJson)

pub struct PathDiff {
  before : Array[AsSegment]
  after : Array[AsSegment]
} derive(ToJson)

pub struct Peer {
  bgp_id : UInt
  address : String
  asn : UInt
} derive(ToJson)

pub struct PeerRecord {
  peer : String
  data : Bytes
  event_indices : Array[Int]
}

pub struct PeerTable {
  collector_id : UInt
  view_name : Bytes
  peers : Array[Peer]
}

pub struct Prefix {
  afi : Int
  length : Int
  address : Bytes
} derive(Eq, ToJson)

pub struct PrefixRanking {
  prefix : String
  changed_events : Int
  change_notices : Int64
  affected_peers : Int
  change_types : Map[String, Int64]
} derive(ToJson)

pub struct Query {
  // private fields
}

pub struct RawAttribute {
  flags : Int
  code : Int
  value : Bytes
} derive(Eq, Hash)

pub struct RouteDiff {
  atomic_aggregate : AtomicAggregateDiff?
  aggregator : AggregatorDiff?
  path : PathDiff?
  origin_as : OriginDiff?
  next_hop : HopDiff?
  communities : CommunityDiff?
  large_communities : LargeCommunityDiff?
} derive(ToJson)