Package io.deephaven.server.notebook

Class FilesystemStorageServiceGrpcImpl

java.lang.Object

io.deephaven.proto.backplane.grpc.StorageServiceGrpc.StorageServiceImplBase

io.deephaven.server.notebook.FilesystemStorageServiceGrpcImpl

All Implemented Interfaces:

StorageServiceGrpc.AsyncService, io.grpc.BindableService

@Singleton
public class FilesystemStorageServiceGrpcImpl
extends StorageServiceGrpc.StorageServiceImplBase

Default implementation for the StorageService gRPC service, which will use the filesystem to store files on behalf of authenticated clients.

Current implementation only checks if a user is logged in, and doesn't provide finer grained access controls to files.

Constructor Summary

Constructors

Constructor	Description
FilesystemStorageServiceGrpcImpl(SessionService sessionService, SessionService.ErrorTransformer errorTransformer)

Method Summary

Modifier and Type	Method	Description
void	createDirectory(@NotNull CreateDirectoryRequest request, @NotNull io.grpc.stub.StreamObserver<CreateDirectoryResponse> responseObserver)	Creates a directory at the given path.
void	deleteItem(@NotNull DeleteItemRequest request, @NotNull io.grpc.stub.StreamObserver<DeleteItemResponse> responseObserver)	Deletes the file or directory at the given path.
void	fetchFile(@NotNull FetchFileRequest request, @NotNull io.grpc.stub.StreamObserver<FetchFileResponse> responseObserver)	Reads the file at the given path.
void	listItems(@NotNull ListItemsRequest request, @NotNull io.grpc.stub.StreamObserver<ListItemsResponse> responseObserver)	Lists the files and directories present in a given directory.
void	moveItem(@NotNull MoveItemRequest request, @NotNull io.grpc.stub.StreamObserver<MoveItemResponse> responseObserver)	Moves a file from one path to another.
void	saveFile(@NotNull SaveFileRequest request, @NotNull io.grpc.stub.StreamObserver<SaveFileResponse> responseObserver)	Can create new files or modify existing with client provided contents.

Methods inherited from class io.deephaven.proto.backplane.grpc.StorageServiceGrpc.StorageServiceImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FilesystemStorageServiceGrpcImpl

@Inject
public FilesystemStorageServiceGrpcImpl(SessionService sessionService,
 SessionService.ErrorTransformer errorTransformer)

Method Details

listItems

public void listItems(@NotNull
 @NotNull ListItemsRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<ListItemsResponse> responseObserver)

Description copied from interface: StorageServiceGrpc.AsyncService

 Lists the files and directories present in a given directory. Will return an error
 

fetchFile

public void fetchFile(@NotNull
 @NotNull FetchFileRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<FetchFileResponse> responseObserver)

Description copied from interface: StorageServiceGrpc.AsyncService

 Reads the file at the given path. Client can optionally specify an etag, asking the server
 not to send the file if it hasn't changed.
 

saveFile

public void saveFile(@NotNull
 @NotNull SaveFileRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<SaveFileResponse> responseObserver)

Description copied from interface: StorageServiceGrpc.AsyncService

 Can create new files or modify existing with client provided contents.
 

moveItem

public void moveItem(@NotNull
 @NotNull MoveItemRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<MoveItemResponse> responseObserver)

Description copied from interface: StorageServiceGrpc.AsyncService

 Moves a file from one path to another.
 

createDirectory

public void createDirectory(@NotNull
 @NotNull CreateDirectoryRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<CreateDirectoryResponse> responseObserver)

Description copied from interface: StorageServiceGrpc.AsyncService

 Creates a directory at the given path.
 

deleteItem

public void deleteItem(@NotNull
 @NotNull DeleteItemRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<DeleteItemResponse> responseObserver)

Description copied from interface: StorageServiceGrpc.AsyncService

 Deletes the file or directory at the given path. Directories must be empty to be deleted.