Skip to content

Commit

Permalink
Add placeholder implementations.
Browse files Browse the repository at this point in the history
Signed-off-by: Cody Littley <[email protected]>
  • Loading branch information
cody-littley committed Aug 29, 2024
1 parent 45bb359 commit d8e15e8
Show file tree
Hide file tree
Showing 3 changed files with 38 additions and 0 deletions.
8 changes: 8 additions & 0 deletions disperser/apiserver/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"context"
"errors"
"fmt"
"google.golang.org/grpc/status"
"math/rand"
"net"
"slices"
Expand Down Expand Up @@ -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
}
Expand Down
23 changes: 23 additions & 0 deletions node/grpc/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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()

Expand Down
7 changes: 7 additions & 0 deletions retriever/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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")
}

0 comments on commit d8e15e8

Please sign in to comment.