beamtrace/anomaly

Types

Alert

pub type Alert {
  Alert(
    kind: AnomalyKind,
    summary: String,
    evidence: types.Evidence,
    opened_at_ns: Int,
  )
}

Constructors

Alert(
  kind: AnomalyKind,
  summary: String,
  evidence: types.Evidence,
  opened_at_ns: Int,
)

AnomalyKind

</>

pub type AnomalyKind {
  MailboxGrowth
  MemoryGrowth
  HeapGrowth
  ReductionSpike
  ProcessLeak
  RestartStorm
  BusyDistributionPort
  LongGarbageCollection
  LongSchedule
  LargeHeap
}

Constructors

```
MailboxGrowth
```
```
MemoryGrowth
```
```
HeapGrowth
```
```
ReductionSpike
```
```
ProcessLeak
```
```
RestartStorm
```
```
BusyDistributionPort
```
```
LongGarbageCollection
```
```
LongSchedule
```
```
LargeHeap
```

Baseline

</>

pub type Baseline {
  Baseline(
    metric: Metric,
    ewma: Float,
    initialized: Bool,
    high_samples: Int,
    low_samples: Int,
  )
}

Constructors

Baseline(
  metric: Metric,
  ewma: Float,
  initialized: Bool,
  high_samples: Int,
  low_samples: Int,
)

Detector

</>

pub type Detector {
  Detector(
    alpha: Float,
    open_after: Int,
    close_after: Int,
    baselines: List(Baseline),
    active: List(Alert),
  )
}

Constructors

Detector(
  alpha: Float,
  open_after: Int,
  close_after: Int,
  baselines: List(Baseline),
  active: List(Alert),
)

Metric

</>

pub type Metric {
  Mailbox
  Memory
  Heap
  Reductions
  ProcessCount
  RestartCount
  DistributionQueue
}

Constructors

```
Mailbox
```
```
Memory
```
```
Heap
```
```
Reductions
```
```
ProcessCount
```
```
RestartCount
```
```
DistributionQueue
```

SystemSignal

</>

pub type SystemSignal {
  LongGc
  LongScheduleSignal
  LargeHeapSignal
  BusyDistPort
}

Constructors

```
LongGc
```
```
LongScheduleSignal
```
```
LargeHeapSignal
```
```
BusyDistPort
```

Values

from_system_signal

</>

pub fn from_system_signal(
  signal: SystemSignal,
  value: Int,
) -> Alert

new_detector

</>

pub fn new_detector(
  alpha alpha: Float,
  open_after open_after: Int,
  close_after close_after: Int,
) -> Detector

observe

</>

pub fn observe(
  detector: Detector,
  metric: Metric,
  value: Float,
  observed_at_ns: Int,
) -> Detector