Skip to content

Commit

Permalink
Made suggested change, removed RPC that won't be used in v1
Browse files Browse the repository at this point in the history
Signed-off-by: Cody Littley <[email protected]>
  • Loading branch information
cody-littley committed Sep 18, 2024
1 parent 9f44421 commit 9ac3965
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 27 deletions.
24 changes: 6 additions & 18 deletions api/proto/lightnode/lightnode.proto
Original file line number Diff line number Diff line change
Expand Up @@ -8,23 +8,11 @@ option go_package = "github.com/Layr-Labs/eigenda/api/grpc/lightnode";
/////////////////////////////////////////////////////////////////////////////////////

service LightNode {
// GetChunk retrieves a specific chunk held by the light node.
rpc GetChunk(GetChunkRequest) returns (GetChunkReply) {}

// StreamAvailabilityStatus streams the availability status of all chunks assigned to the light node.
// For use by a DA node for monitoring the availability of chunks through its constellation of agent light nodes.
rpc StreamChunkAvailability(StreamChunkAvailabilityRequest) returns (stream StreamChunkAvailabilityReply) {}
}

// A request for a specific chunk from a light node.
message GetChunkRequest {
bytes header_hash = 1;
}

// A reply to a GetChunk request.
message GetChunkReply {
// The chunk data.
common.ChunkData chunk = 1;
// StreamBlobAvailability streams the availability status blobs from the light node's perspective.
// A light node considers a blob to be available if all chunks it wants to sample are available.
// This API is for use by a DA node for monitoring the availability of chunks through its
// constellation of agent light nodes.
rpc StreamBlobAvailability(StreamChunkAvailabilityRequest) returns (stream StreamChunkAvailabilityReply) {}
}

// A request from a DA node to an agent light node to stream the availability status of all chunks
Expand All @@ -36,6 +24,6 @@ message StreamChunkAvailabilityRequest {
// A reply to a StreamAvailabilityStatus request.
message StreamChunkAvailabilityReply {
// The hash of a blob header corresponding to a chunk the agent received and verified. From the light node's
// perspective, the blob is available if the chunk is available.
// perspective, the blob is available if all chunks the light node wants to sample are available.
bytes header_hash = 1;
}
18 changes: 9 additions & 9 deletions api/proto/relay/relay.proto
Original file line number Diff line number Diff line change
Expand Up @@ -9,22 +9,22 @@ option go_package = "github.com/Layr-Labs/eigenda/api/grpc/relay";
/////////////////////////////////////////////////////////////////////////////////////

service Relay {
// Note: the relay API is still being fleshed out. This definition is not yet complete.
// Note: the relay API is still being fleshed out. This definition is not yet complete.

// GetChunk retrieves a specific chunk for a blob custodied at the Node.
rpc GetChunk(GetChunkRequest) returns (GetChunkReply) {}
// GetChunk retrieves a specific chunk for a blob custodied at the Node.
rpc GetChunk(GetChunkRequest) returns (GetChunkReply) {}
}

// Request a specific chunk
message GetChunkRequest {
// The hash of the blob's header.
bytes header_hash = 1;
// The index of the chunk within the blob.
uint32 chunk_index = 2;
// The hash of the blob's header.
bytes header_hash = 1;
// The index of the chunk within the blob.
uint32 chunk_index = 2;
}

// Reply to GetChunkRequest
message GetChunkReply {
// The chunk requested.
common.ChunkData chunk = 1;
// The chunk requested.
common.ChunkData chunk = 1;
}

0 comments on commit 9ac3965

Please sign in to comment.