public abstract static class FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase extends Object implements io.grpc.BindableService
This interface contains file system master service endpoints for Alluxio workers.
Constructor and Description |
---|
FileSystemMasterWorkerServiceImplBase() |
Modifier and Type | Method and Description |
---|---|
io.grpc.ServerServiceDefinition |
bindService() |
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.
|
public FileSystemMasterWorkerServiceImplBase()
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.
public final io.grpc.ServerServiceDefinition bindService()
bindService
in interface io.grpc.BindableService
Copyright © 2023. All Rights Reserved.