syntax = "proto3";

package shredstream;

service ShredstreamProxy {
  // Subscribe to shreds and heartbeats
  rpc SubscribeEntries (SubscribeEntriesRequest) returns (stream SubscribeEntriesResponse);
}

message SubscribeEntriesRequest {
  // Optional filters could go here
}

message SubscribeEntriesResponse {
  uint64 slot = 1;
  uint32 index = 2;
  uint32 shred_type = 3; // 0x5a for data, 0x69 for coding
  bytes data = 4;
}