alluxio.grpc

Class BlockWorkerGrpc.BlockWorkerBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<BlockWorkerGrpc.BlockWorkerBlockingStub>

alluxio.grpc.BlockWorkerGrpc.BlockWorkerBlockingStub

Enclosing class:

BlockWorkerGrpc

public static final class BlockWorkerGrpc.BlockWorkerBlockingStub
extends io.grpc.stub.AbstractBlockingStub<BlockWorkerGrpc.BlockWorkerBlockingStub>

A stub to allow clients to do synchronous 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
AsyncCacheResponse	asyncCache(AsyncCacheRequest request)
protected BlockWorkerGrpc.BlockWorkerBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
CacheResponse	cache(CacheRequest request)
ClearMetricsResponse	clearMetrics(ClearMetricsRequest request) TODO(lu) Move to metrics worker
CompleteFilePResponse	completeFile(CompleteFilePRequest request) Marks a file as completed.
CopyResponse	copy(CopyRequest request)
CreateDirectoryPResponse	createDirectory(CreateDirectoryPRequest request) Creates a directory.
CreateFilePResponse	createFile(CreateFilePRequest request) Creates a file.
ExistsPResponse	exists(ExistsPRequest request) Checks the existence of a file or directory.
FreeWorkerResponse	freeWorker(FreeWorkerRequest request)
GetStatusPResponse	getStatus(GetStatusPRequest request) Returns the status of the file or directory.
Iterator<ListStatusPResponse>	listStatus(ListStatusPRequest request) If the path points to a file, the method returns a singleton with its file information.
LoadResponse	load(LoadRequest request)
LoadFileResponse	loadFile(LoadFileRequest request)
MoveResponse	move(MoveRequest request)
MoveBlockResponse	moveBlock(MoveBlockRequest request)
DeletePResponse	remove(DeletePRequest request) Deletes a file or a directory and returns whether the remove operation succeeded.
RemoveBlockResponse	removeBlock(RemoveBlockRequest request)
RenamePResponse	rename(RenamePRequest request) Renames a file or a directory.
SetAttributePResponse	setAttribute(SetAttributePRequest request) Sets file or directory attributes.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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.BlockWorkerBlockingStub build(io.grpc.Channel channel,
                                                        io.grpc.CallOptions callOptions)

Specified by:

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

getStatus

public GetStatusPResponse getStatus(GetStatusPRequest request)

 Returns the status of the file or directory.
 

listStatus

public Iterator<ListStatusPResponse> listStatus(ListStatusPRequest request)

 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.
 

asyncCache

public AsyncCacheResponse asyncCache(AsyncCacheRequest request)

cache

public CacheResponse cache(CacheRequest request)

load

public LoadResponse load(LoadRequest request)

loadFile

public LoadFileResponse loadFile(LoadFileRequest request)

copy

public CopyResponse copy(CopyRequest request)

removeBlock

public RemoveBlockResponse removeBlock(RemoveBlockRequest request)

moveBlock

public MoveBlockResponse moveBlock(MoveBlockRequest request)

move

public MoveResponse move(MoveRequest request)

clearMetrics

public ClearMetricsResponse clearMetrics(ClearMetricsRequest request)

 TODO(lu) Move to metrics worker
 

freeWorker

public FreeWorkerResponse freeWorker(FreeWorkerRequest request)

createFile

public CreateFilePResponse createFile(CreateFilePRequest request)

 Creates a file.
 

completeFile

public CompleteFilePResponse completeFile(CompleteFilePRequest request)

 Marks a file as completed.
 

remove

public DeletePResponse remove(DeletePRequest request)

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

rename

public RenamePResponse rename(RenamePRequest request)

 Renames a file or a directory.
 

createDirectory

public CreateDirectoryPResponse createDirectory(CreateDirectoryPRequest request)

 Creates a directory.
 

exists

public ExistsPResponse exists(ExistsPRequest request)

 Checks the existence of a file or directory.
 

setAttribute

public SetAttributePResponse setAttribute(SetAttributePRequest request)

 Sets file or directory attributes.