alluxio.grpc

Interface BlockWorkerGrpc.AsyncService

All Known Implementing Classes:

BlockWorkerGrpc.BlockWorkerImplBase, DoraWorkerClientServiceHandler

Enclosing class:

BlockWorkerGrpc

public static interface BlockWorkerGrpc.AsyncService

 The block worker service
 

Method Summary

Modifier and Type	Method and Description
default void	asyncCache(AsyncCacheRequest request, io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)
default void	cache(CacheRequest request, io.grpc.stub.StreamObserver<CacheResponse> responseObserver)
default void	clearMetrics(ClearMetricsRequest request, io.grpc.stub.StreamObserver<ClearMetricsResponse> responseObserver) TODO(lu) Move to metrics worker
default void	completeFile(CompleteFilePRequest request, io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver) Marks a file as completed.
default void	copy(CopyRequest request, io.grpc.stub.StreamObserver<CopyResponse> responseObserver)
default void	createDirectory(CreateDirectoryPRequest request, io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver) Creates a directory.
default void	createFile(CreateFilePRequest request, io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver) Creates a file.
default void	exists(ExistsPRequest request, io.grpc.stub.StreamObserver<ExistsPResponse> responseObserver) Checks the existence of a file or directory.
default void	freeWorker(FreeWorkerRequest request, io.grpc.stub.StreamObserver<FreeWorkerResponse> responseObserver)
default void	getStatus(GetStatusPRequest request, io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver) Returns the status of the file or directory.
default void	listStatus(ListStatusPRequest request, io.grpc.stub.StreamObserver<ListStatusPResponse> responseObserver) If the path points to a file, the method returns a singleton with its file information.
default void	load(LoadRequest request, io.grpc.stub.StreamObserver<LoadResponse> responseObserver)
default void	loadFile(LoadFileRequest request, io.grpc.stub.StreamObserver<LoadFileResponse> responseObserver)
default void	move(MoveRequest request, io.grpc.stub.StreamObserver<MoveResponse> responseObserver)
default void	moveBlock(MoveBlockRequest request, io.grpc.stub.StreamObserver<MoveBlockResponse> responseObserver)
default io.grpc.stub.StreamObserver<ReadRequest>	readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
default void	remove(DeletePRequest request, io.grpc.stub.StreamObserver<DeletePResponse> responseObserver) Deletes a file or a directory and returns whether the remove operation succeeded.
default void	removeBlock(RemoveBlockRequest request, io.grpc.stub.StreamObserver<RemoveBlockResponse> responseObserver)
default void	rename(RenamePRequest request, io.grpc.stub.StreamObserver<RenamePResponse> responseObserver) Renames a file or a directory.
default void	setAttribute(SetAttributePRequest request, io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver) Sets file or directory attributes.
default io.grpc.stub.StreamObserver<WriteRequest>	writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

Method Detail

getStatus

default void getStatus(GetStatusPRequest request,
                       io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver)

 Returns the status of the file or directory.
 

listStatus

default void listStatus(ListStatusPRequest request,
                        io.grpc.stub.StreamObserver<ListStatusPResponse> responseObserver)

 If the path points to a file, the method returns a singleton with its file information.
 If the path points to a directory, the method returns a list with file information for the
 directory contents.
 

readBlock

default io.grpc.stub.StreamObserver<ReadRequest> readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)

writeBlock

default io.grpc.stub.StreamObserver<WriteRequest> writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

asyncCache

default void asyncCache(AsyncCacheRequest request,
                        io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)

cache

default void cache(CacheRequest request,
                   io.grpc.stub.StreamObserver<CacheResponse> responseObserver)

load

default void load(LoadRequest request,
                  io.grpc.stub.StreamObserver<LoadResponse> responseObserver)

loadFile

default void loadFile(LoadFileRequest request,
                      io.grpc.stub.StreamObserver<LoadFileResponse> responseObserver)

copy

default void copy(CopyRequest request,
                  io.grpc.stub.StreamObserver<CopyResponse> responseObserver)

removeBlock

default void removeBlock(RemoveBlockRequest request,
                         io.grpc.stub.StreamObserver<RemoveBlockResponse> responseObserver)

moveBlock

default void moveBlock(MoveBlockRequest request,
                       io.grpc.stub.StreamObserver<MoveBlockResponse> responseObserver)

move

default void move(MoveRequest request,
                  io.grpc.stub.StreamObserver<MoveResponse> responseObserver)

clearMetrics

default void clearMetrics(ClearMetricsRequest request,
                          io.grpc.stub.StreamObserver<ClearMetricsResponse> responseObserver)

 TODO(lu) Move to metrics worker
 

freeWorker

default void freeWorker(FreeWorkerRequest request,
                        io.grpc.stub.StreamObserver<FreeWorkerResponse> responseObserver)

createFile

default void createFile(CreateFilePRequest request,
                        io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver)

 Creates a file.
 

completeFile

default void completeFile(CompleteFilePRequest request,
                          io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver)

 Marks a file as completed.
 

remove

default void remove(DeletePRequest request,
                    io.grpc.stub.StreamObserver<DeletePResponse> responseObserver)

 Deletes a file or a directory and returns whether the remove operation succeeded.
 

rename

default void rename(RenamePRequest request,
                    io.grpc.stub.StreamObserver<RenamePResponse> responseObserver)

 Renames a file or a directory.
 

createDirectory

default void createDirectory(CreateDirectoryPRequest request,
                             io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver)

 Creates a directory.
 

exists

default void exists(ExistsPRequest request,
                    io.grpc.stub.StreamObserver<ExistsPResponse> responseObserver)

 Checks the existence of a file or directory.
 

setAttribute

default void setAttribute(SetAttributePRequest request,
                          io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver)

 Sets file or directory attributes.