public static final class FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceStub extends io.grpc.stub.AbstractAsyncStub<FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceStub>
This interface contains file system master service endpoints for Alluxio workers.
Modifier and Type | Method and Description |
---|---|
protected FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
void |
fileSystemHeartbeat(FileSystemHeartbeatPRequest request,
io.grpc.stub.StreamObserver<FileSystemHeartbeatPResponse> responseObserver)
Periodic file system worker heartbeat.
|
void |
getFileInfo(GetFileInfoPRequest request,
io.grpc.stub.StreamObserver<GetFileInfoPResponse> responseObserver)
Returns the file information for a file or directory identified by the given file id.
|
void |
getPinnedFileIds(GetPinnedFileIdsPRequest request,
io.grpc.stub.StreamObserver<GetPinnedFileIdsPResponse> responseObserver)
Returns the set of pinned file ids.
|
void |
getUfsInfo(GetUfsInfoPRequest request,
io.grpc.stub.StreamObserver<GetUfsInfoPResponse> responseObserver)
Returns the UFS information for the given mount point identified by its id.
|
protected FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceStub>
public void fileSystemHeartbeat(FileSystemHeartbeatPRequest request, io.grpc.stub.StreamObserver<FileSystemHeartbeatPResponse> responseObserver)
Periodic file system worker heartbeat. Returns the command for persisting the blocks of a file.
public void getFileInfo(GetFileInfoPRequest request, io.grpc.stub.StreamObserver<GetFileInfoPResponse> responseObserver)
Returns the file information for a file or directory identified by the given file id.
public void getPinnedFileIds(GetPinnedFileIdsPRequest request, io.grpc.stub.StreamObserver<GetPinnedFileIdsPResponse> responseObserver)
Returns the set of pinned file ids.
public void getUfsInfo(GetUfsInfoPRequest request, io.grpc.stub.StreamObserver<GetUfsInfoPResponse> responseObserver)
Returns the UFS information for the given mount point identified by its id.
Copyright © 2023. All Rights Reserved.