public final class FileSystemMasterWorkerServiceHandler extends FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase
Constructor and Description |
---|
FileSystemMasterWorkerServiceHandler(FileSystemMaster fileSystemMaster)
Creates a new instance of
FileSystemMasterWorkerServiceHandler . |
Modifier and Type | Method and Description |
---|---|
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.
|
bindService
public FileSystemMasterWorkerServiceHandler(FileSystemMaster fileSystemMaster)
FileSystemMasterWorkerServiceHandler
.fileSystemMaster
- the FileSystemMaster
the handler uses internallypublic void fileSystemHeartbeat(FileSystemHeartbeatPRequest request, io.grpc.stub.StreamObserver<FileSystemHeartbeatPResponse> responseObserver)
FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase
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)
FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase
Returns the file information for a file or directory identified by the given file id.
getFileInfo
in class FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase
public void getPinnedFileIds(GetPinnedFileIdsPRequest request, io.grpc.stub.StreamObserver<GetPinnedFileIdsPResponse> responseObserver)
FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase
Returns the set of pinned file ids.
public void getUfsInfo(GetUfsInfoPRequest request, io.grpc.stub.StreamObserver<GetUfsInfoPResponse> responseObserver)
FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase
Returns the UFS information for the given mount point identified by its id.
getUfsInfo
in class FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase
Copyright © 2023. All Rights Reserved.