femboy/emry

Watch

EMRY-010: Processor trait + pipeline thread #8

New issue

Closed

opened 2026-06-24 00:20:45 +00:00 by vxfemboy · 1 comment

vxfemboy commented

2026-06-24 00:20:45 +00:00

(Migrated from github.com)

Processor pipeline

Tasks

trait Processor { fn on_event(&mut self, &Event) -> Vec<DerivedMetric>; }
Pipeline thread: drain ring → run processors → publish DerivedState
Graceful shutdown on RunFinished

Acceptance

Integration test with no-op processor

Depends on: EMRY-004, EMRY-006
Estimate: 8h

## Processor pipeline ### Tasks - [ ] `trait Processor { fn on_event(&mut self, &Event) -> Vec<DerivedMetric>; }` - [ ] Pipeline thread: drain ring → run processors → publish DerivedState - [ ] Graceful shutdown on RunFinished ### Acceptance - [ ] Integration test with no-op processor **Depends on:** EMRY-004, EMRY-006 **Estimate:** 8h

vxfemboy commented

2026-06-25 11:45:37 +00:00

(Migrated from github.com)

Completed and merged in PR #55.

Completed and merged in PR #55.

Sign in to join this conversation.

No labels

good first issue

No milestone

No project

No assignees

1 participant

Notifications

Due date

The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set

Reference

femboy/emry#8

No description provided.