Documentation ¶
Index ¶
- func MainCommand() *cobra.Command
- type Config
- type Server
- func (s *Server) CheckBlob(ctx context.Context, req *goproto.BlobKey) (*goproto.CheckBlobResp, error)
- func (s *Server) CreateBlob(_ context.Context, req *goproto.CreateBlobReq) (*emptypb.Empty, error)
- func (s *Server) DeleteBlob(_ context.Context, req *goproto.BlobKey) (*emptypb.Empty, error)
- func (s *Server) ListBlob(_ context.Context, req *goproto.ListBlobReq) (*goproto.ListBlobResp, error)
- func (s *Server) QueryWriteStatus(ctx context.Context, request *bytestream.QueryWriteStatusRequest) (*bytestream.QueryWriteStatusResponse, error)
- func (s *Server) Read(request *bytestream.ReadRequest, server bytestream.ByteStream_ReadServer) error
- func (s *Server) ServeHTTP(rw http.ResponseWriter, r *http.Request)
- func (s *Server) StatBlob(_ context.Context, req *goproto.BlobKey) (*goproto.BlobInfo, error)
- func (s *Server) Write(server bytestream.ByteStream_WriteServer) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MainCommand ¶
Types ¶
type Server ¶
type Server struct { goproto.UnimplementedBlobServiceServer // contains filtered or unexported fields }
func (*Server) CreateBlob ¶
func (*Server) DeleteBlob ¶
func (*Server) ListBlob ¶
func (s *Server) ListBlob(_ context.Context, req *goproto.ListBlobReq) (*goproto.ListBlobResp, error)
func (*Server) QueryWriteStatus ¶
func (s *Server) QueryWriteStatus(ctx context.Context, request *bytestream.QueryWriteStatusRequest) (*bytestream.QueryWriteStatusResponse, error)
func (*Server) Read ¶
func (s *Server) Read(request *bytestream.ReadRequest, server bytestream.ByteStream_ReadServer) error
func (*Server) Write ¶
func (s *Server) Write(server bytestream.ByteStream_WriteServer) (err error)
Click to show internal directories.
Click to hide internal directories.