diff --git a/disperser/apiserver/server.go b/disperser/apiserver/server.go index 4dbf48de20..ca7595b20f 100644 --- a/disperser/apiserver/server.go +++ b/disperser/apiserver/server.go @@ -4,6 +4,7 @@ import ( "context" "errors" "fmt" + "google.golang.org/grpc/status" "math/rand" "net" "slices" @@ -776,6 +777,13 @@ func (s *DispersalServer) RetrieveBlob(ctx context.Context, req *pb.RetrieveBlob }, nil } +func (s *DispersalServer) GetBlob(context.Context, *commonpb.BlobKey) (*commonpb.BlobData, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetBlob not implemented") +} +func (s *DispersalServer) GetChunk(context.Context, *commonpb.ChunkKey) (*commonpb.ChunkData, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetChunk not implemented") +} + func (s *DispersalServer) GetRateConfig() *RateConfig { return &s.rateConfig } diff --git a/node/grpc/server.go b/node/grpc/server.go index 65ee30df61..f77bcfe0d2 100644 --- a/node/grpc/server.go +++ b/node/grpc/server.go @@ -5,6 +5,9 @@ import ( "encoding/hex" "errors" "fmt" + commonpb "github.com/Layr-Labs/eigenda/api/grpc/common" + "google.golang.org/grpc/codes" + "google.golang.org/grpc/status" "reflect" "runtime" "sync" @@ -154,6 +157,26 @@ func (s *Server) NodeInfo(ctx context.Context, in *pb.NodeInfoRequest) (*pb.Node return &pb.NodeInfoReply{Semver: node.SemVer, Os: runtime.GOOS, Arch: runtime.GOARCH, NumCpu: uint32(runtime.GOMAXPROCS(0)), MemBytes: memBytes}, nil } +func (s *Server) GetChunks(context.Context, *pb.GetChunksRequest) (*pb.GetChunksReply, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetChunks not implemented") +} + +func (s *Server) GetChunk(context.Context, *commonpb.ChunkKey) (*commonpb.ChunkData, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetChunk not implemented") +} + +func (s *Server) GetHeader(context.Context, *commonpb.BlobKey) (*pb.GetBlobHeaderReply, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetHeader not implemented") +} + +func (s *Server) StreamHeaders(grpc.BidiStreamingServer[pb.StreamHeadersRequest, pb.GetBlobHeaderReply]) error { + return status.Errorf(codes.Unimplemented, "method StreamHeaders not implemented") +} + +func (s *Server) GetNodeInfo(context.Context, *pb.GetNodeInfoRequest) (*pb.GetNodeInfoReply, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetNodeInfo not implemented") +} + func (s *Server) handleStoreChunksRequest(ctx context.Context, in *pb.StoreChunksRequest) (*pb.StoreChunksReply, error) { start := time.Now() diff --git a/retriever/server.go b/retriever/server.go index d49f8dbf7f..3127d40de9 100644 --- a/retriever/server.go +++ b/retriever/server.go @@ -3,6 +3,9 @@ package retriever import ( "context" "errors" + "github.com/Layr-Labs/eigenda/api/grpc/common" + "google.golang.org/grpc/codes" + "google.golang.org/grpc/status" "math/big" "github.com/Layr-Labs/eigenda/api/clients" @@ -76,3 +79,7 @@ func (s *Server) RetrieveBlob(ctx context.Context, req *pb.BlobRequest) (*pb.Blo Data: data, }, nil } + +func (s *Server) GetBlob(context.Context, *common.BlobKey) (*common.BlobData, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetBlob not implemented") +}