alluxio.worker.grpc

Class DoraWorkerClientServiceHandler

java.lang.Object

alluxio.grpc.BlockWorkerGrpc.BlockWorkerImplBase

alluxio.worker.grpc.DoraWorkerClientServiceHandler

All Implemented Interfaces:

BlockWorkerGrpc.AsyncService, io.grpc.BindableService

public class DoraWorkerClientServiceHandler
extends BlockWorkerGrpc.BlockWorkerImplBase

Server side implementation of the gRPC dora worker interface.

Constructor Summary

Constructors

Constructor and Description
DoraWorkerClientServiceHandler(DoraWorker doraWorker) Creates a new implementation of gRPC BlockWorker interface.

Method Summary

Modifier and Type	Method and Description
void	completeFile(CompleteFilePRequest request, io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver) Marks a file as completed.
void	copy(CopyRequest request, io.grpc.stub.StreamObserver<CopyResponse> responseObserver)
void	createDirectory(CreateDirectoryPRequest request, io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver) Creates a directory.
void	createFile(CreateFilePRequest request, io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver) Creates a file.
void	exists(ExistsPRequest request, io.grpc.stub.StreamObserver<ExistsPResponse> responseObserver) Checks the existence of a file or directory.
Map<io.grpc.MethodDescriptor,io.grpc.MethodDescriptor>	getOverriddenMethodDescriptors()
void	getStatus(GetStatusPRequest request, io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver) Returns the status of the file or directory.
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.
void	loadFile(LoadFileRequest request, io.grpc.stub.StreamObserver<LoadFileResponse> responseObserver)
void	move(MoveRequest request, io.grpc.stub.StreamObserver<MoveResponse> responseObserver)
io.grpc.stub.StreamObserver<ReadRequest>	readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
void	remove(DeletePRequest request, io.grpc.stub.StreamObserver<DeletePResponse> responseObserver) Deletes a file or a directory and returns whether the remove operation succeeded.
void	rename(RenamePRequest request, io.grpc.stub.StreamObserver<RenamePResponse> responseObserver) Renames a file or a directory.
void	setAttribute(SetAttributePRequest request, io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver) Sets file or directory attributes.

Methods inherited from class alluxio.grpc.BlockWorkerGrpc.BlockWorkerImplBase

bindService

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.grpc.BlockWorkerGrpc.AsyncService

asyncCache, cache, clearMetrics, freeWorker, load, moveBlock, removeBlock, writeBlock

Constructor Detail

DoraWorkerClientServiceHandler

@Inject
public DoraWorkerClientServiceHandler(DoraWorker doraWorker)

Creates a new implementation of gRPC BlockWorker interface.

Parameters:

doraWorker - the DoraWorker object

Method Detail

getOverriddenMethodDescriptors

public Map<io.grpc.MethodDescriptor,io.grpc.MethodDescriptor> getOverriddenMethodDescriptors()

Returns:

a map of gRPC methods with overridden descriptors

readBlock

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

loadFile

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

copy

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

move

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

getStatus

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

Description copied from interface: BlockWorkerGrpc.AsyncService

 Returns the status of the file or directory.
 

listStatus

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

Description copied from interface: BlockWorkerGrpc.AsyncService

 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.
 

createFile

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

Description copied from interface: BlockWorkerGrpc.AsyncService

 Creates a file.
 

completeFile

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

Description copied from interface: BlockWorkerGrpc.AsyncService

 Marks a file as completed.
 

remove

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

Description copied from interface: BlockWorkerGrpc.AsyncService

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

rename

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

Description copied from interface: BlockWorkerGrpc.AsyncService

 Renames a file or a directory.
 

createDirectory

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

Description copied from interface: BlockWorkerGrpc.AsyncService

 Creates a directory.
 

exists

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

Description copied from interface: BlockWorkerGrpc.AsyncService

 Checks the existence of a file or directory.
 

setAttribute

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

Description copied from interface: BlockWorkerGrpc.AsyncService

 Sets file or directory attributes.