Skip to content

[M1] ShardedStreamer: shard-filtered NEAR Lake wrapper #1

@Fosurero

Description

@Fosurero

Description

Implement ShardedStreamer that wraps near-lake-framework and filters StreamerMessage by shard_id.

Tasks

  • ShardedLakeConfig with network, start_block, shard_ids
  • ShardedStreamer::new() constructor
  • build_lake_config() for real NEAR Lake connections
  • should_include_shard() filter predicate
  • stream_demo() synthetic data generator
  • streamer_message_to_shard_blocks() conversion function
  • Unit tests

Status: ✅ Complete – M1 PoC

Metadata

Metadata

Assignees

No one assigned

    Labels

    M1Milestone 1: Core PoCenhancementNew feature or request

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions