alluxio.grpc

Class BlockWorkerGrpc.BlockWorkerStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<BlockWorkerGrpc.BlockWorkerStub>

alluxio.grpc.BlockWorkerGrpc.BlockWorkerStub

Enclosing class:

BlockWorkerGrpc

public static final class BlockWorkerGrpc.BlockWorkerStub
extends io.grpc.stub.AbstractAsyncStub<BlockWorkerGrpc.BlockWorkerStub>

A stub to allow clients to do asynchronous rpc calls to service BlockWorker.

 The block worker service
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
void	asyncCache(AsyncCacheRequest request, io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)
protected BlockWorkerGrpc.BlockWorkerStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	cache(CacheRequest request, io.grpc.stub.StreamObserver<CacheResponse> responseObserver)
void	clearMetrics(ClearMetricsRequest request, io.grpc.stub.StreamObserver<ClearMetricsResponse> responseObserver) TODO(lu) Move to metrics worker
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.
void	freeWorker(FreeWorkerRequest request, io.grpc.stub.StreamObserver<FreeWorkerResponse> responseObserver)
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	load(LoadRequest request, io.grpc.stub.StreamObserver<LoadResponse> responseObserver)
void	loadFile(LoadFileRequest request, io.grpc.stub.StreamObserver<LoadFileResponse> responseObserver)
void	move(MoveRequest request, io.grpc.stub.StreamObserver<MoveResponse> responseObserver)
void	moveBlock(MoveBlockRequest request, io.grpc.stub.StreamObserver<MoveBlockResponse> 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	removeBlock(RemoveBlockRequest request, io.grpc.stub.StreamObserver<RemoveBlockResponse> responseObserver)
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.
io.grpc.stub.StreamObserver<WriteRequest>	writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected BlockWorkerGrpc.BlockWorkerStub build(io.grpc.Channel channel,
                                                io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<BlockWorkerGrpc.BlockWorkerStub>

getStatus

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

 Returns the status of the file or directory.
 

listStatus

public 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

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

writeBlock

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

asyncCache

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

cache

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

load

public void load(LoadRequest request,
                 io.grpc.stub.StreamObserver<LoadResponse> 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)

removeBlock

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

moveBlock

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

move

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

clearMetrics

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

 TODO(lu) Move to metrics worker
 

freeWorker

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

createFile

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

 Creates a file.
 

completeFile

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

 Marks a file as completed.
 

remove

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

 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)

 Renames a file or a directory.
 

createDirectory

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

 Creates a directory.
 

exists

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

 Checks the existence of a file or directory.
 

setAttribute

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

 Sets file or directory attributes.