Skip to content
This repository was archived by the owner on Jun 2, 2026. It is now read-only.
This repository was archived by the owner on Jun 2, 2026. It is now read-only.

[Reliability] Jetstream events silently dropped under load #15

Description

@daviddao

Review Finding: 3d — MEDIUM

// jetstream/client.go:166
select {
case c.events <- event:
default:
    slog.Warn("Event channel full, dropping event")
}

Events are silently dropped when the channel buffer is full. For an AppView indexer, this means data loss — records that should be indexed are permanently missed.

Fix

Add backpressure: either block (risking WebSocket disconnect), use a growing buffer with limits, or implement a replay mechanism from cursor.

Files

  • internal/jetstream/client.go (line 166)

From codebase review §3d

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions