alluxio.master.file

Class FileSystemMasterWorkerServiceHandler

java.lang.Object

alluxio.grpc.FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

alluxio.master.file.FileSystemMasterWorkerServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

public final class FileSystemMasterWorkerServiceHandler
extends FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

This class is a gRPC handler for file system master RPCs invoked by an Alluxio worker.

Constructor Summary

Constructors

Constructor and Description
FileSystemMasterWorkerServiceHandler(FileSystemMaster fileSystemMaster) Creates a new instance of FileSystemMasterWorkerServiceHandler.

Method Summary

Modifier and Type	Method and Description
void	fileSystemHeartbeat(FileSystemHeartbeatPRequest request, io.grpc.stub.StreamObserver<FileSystemHeartbeatPResponse> responseObserver)
void	getFileInfo(GetFileInfoPRequest request, io.grpc.stub.StreamObserver<GetFileInfoPResponse> responseObserver)
void	getPinnedFileIds(GetPinnedFileIdsPRequest request, io.grpc.stub.StreamObserver<GetPinnedFileIdsPResponse> responseObserver)
void	getUfsInfo(GetUfsInfoPRequest request, io.grpc.stub.StreamObserver<GetUfsInfoPResponse> responseObserver)

Methods inherited from class alluxio.grpc.FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSystemMasterWorkerServiceHandler

public FileSystemMasterWorkerServiceHandler(FileSystemMaster fileSystemMaster)

Creates a new instance of FileSystemMasterWorkerServiceHandler.

Parameters:

fileSystemMaster - the FileSystemMaster the handler uses internally

Method Detail

fileSystemHeartbeat

public void fileSystemHeartbeat(FileSystemHeartbeatPRequest request,
                                io.grpc.stub.StreamObserver<FileSystemHeartbeatPResponse> responseObserver)

Overrides:

fileSystemHeartbeat in class FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

getFileInfo

public void getFileInfo(GetFileInfoPRequest request,
                        io.grpc.stub.StreamObserver<GetFileInfoPResponse> responseObserver)

Overrides:

getFileInfo in class FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

getPinnedFileIds

public void getPinnedFileIds(GetPinnedFileIdsPRequest request,
                             io.grpc.stub.StreamObserver<GetPinnedFileIdsPResponse> responseObserver)

Overrides:

getPinnedFileIds in class FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

getUfsInfo

public void getUfsInfo(GetUfsInfoPRequest request,
                       io.grpc.stub.StreamObserver<GetUfsInfoPResponse> responseObserver)

Overrides:

getUfsInfo in class FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase