alluxio.master.file

Class FileSystemMasterClientServiceHandler

java.lang.Object

alluxio.grpc.FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

alluxio.master.file.FileSystemMasterClientServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

public final class FileSystemMasterClientServiceHandler
extends FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	checkAccess(CheckAccessPRequest request, io.grpc.stub.StreamObserver<CheckAccessPResponse> responseObserver)
void	checkConsistency(CheckConsistencyPRequest request, io.grpc.stub.StreamObserver<CheckConsistencyPResponse> responseObserver)
void	completeFile(CompleteFilePRequest request, io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver)
void	createDirectory(CreateDirectoryPRequest request, io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver)
void	createFile(CreateFilePRequest request, io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver)
void	free(FreePRequest request, io.grpc.stub.StreamObserver<FreePResponse> responseObserver)
void	getFilePath(GetFilePathPRequest request, io.grpc.stub.StreamObserver<GetFilePathPResponse> responseObserver)
void	getMountTable(GetMountTablePRequest request, io.grpc.stub.StreamObserver<GetMountTablePResponse> responseObserver)
void	getNewBlockIdForFile(GetNewBlockIdForFilePRequest request, io.grpc.stub.StreamObserver<GetNewBlockIdForFilePResponse> responseObserver)
void	getStatus(GetStatusPRequest request, io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver)
void	getSyncPathList(GetSyncPathListPRequest request, io.grpc.stub.StreamObserver<GetSyncPathListPResponse> responseObserver)
void	listStatus(ListStatusPRequest request, io.grpc.stub.StreamObserver<ListStatusPResponse> responseObserver)
void	mount(MountPRequest request, io.grpc.stub.StreamObserver<MountPResponse> responseObserver)
void	remove(DeletePRequest request, io.grpc.stub.StreamObserver<DeletePResponse> responseObserver)
void	rename(RenamePRequest request, io.grpc.stub.StreamObserver<RenamePResponse> responseObserver)
void	reverseResolve(ReverseResolvePRequest request, io.grpc.stub.StreamObserver<ReverseResolvePResponse> responseObserver)
void	scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request, io.grpc.stub.StreamObserver<ScheduleAsyncPersistencePResponse> responseObserver)
void	setAcl(SetAclPRequest request, io.grpc.stub.StreamObserver<SetAclPResponse> responseObserver)
void	setAttribute(SetAttributePRequest request, io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver)
void	startSync(StartSyncPRequest request, io.grpc.stub.StreamObserver<StartSyncPResponse> responseObserver)
void	stopSync(StopSyncPRequest request, io.grpc.stub.StreamObserver<StopSyncPResponse> responseObserver)
void	unmount(UnmountPRequest request, io.grpc.stub.StreamObserver<UnmountPResponse> responseObserver)
void	updateMount(UpdateMountPRequest request, io.grpc.stub.StreamObserver<UpdateMountPResponse> responseObserver)
void	updateUfsMode(UpdateUfsModePRequest request, io.grpc.stub.StreamObserver<UpdateUfsModePResponse> responseObserver)

Methods inherited from class alluxio.grpc.FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSystemMasterClientServiceHandler

public FileSystemMasterClientServiceHandler(FileSystemMaster fileSystemMaster)

Creates a new instance of FileSystemMasterClientServiceHandler.

Parameters:

fileSystemMaster - the FileSystemMaster the handler uses internally

Method Detail

checkAccess

public void checkAccess(CheckAccessPRequest request,
                        io.grpc.stub.StreamObserver<CheckAccessPResponse> responseObserver)

Overrides:

checkAccess in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

checkConsistency

public void checkConsistency(CheckConsistencyPRequest request,
                             io.grpc.stub.StreamObserver<CheckConsistencyPResponse> responseObserver)

Overrides:

checkConsistency in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

completeFile

public void completeFile(CompleteFilePRequest request,
                         io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver)

Overrides:

completeFile in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

createDirectory

public void createDirectory(CreateDirectoryPRequest request,
                            io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver)

Overrides:

createDirectory in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

createFile

public void createFile(CreateFilePRequest request,
                       io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver)

Overrides:

createFile in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

free

public void free(FreePRequest request,
                 io.grpc.stub.StreamObserver<FreePResponse> responseObserver)

Overrides:

free in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getNewBlockIdForFile

public void getNewBlockIdForFile(GetNewBlockIdForFilePRequest request,
                                 io.grpc.stub.StreamObserver<GetNewBlockIdForFilePResponse> responseObserver)

Overrides:

getNewBlockIdForFile in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getFilePath

public void getFilePath(GetFilePathPRequest request,
                        io.grpc.stub.StreamObserver<GetFilePathPResponse> responseObserver)

Overrides:

getFilePath in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getStatus

public void getStatus(GetStatusPRequest request,
                      io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver)

Overrides:

getStatus in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

listStatus

public void listStatus(ListStatusPRequest request,
                       io.grpc.stub.StreamObserver<ListStatusPResponse> responseObserver)

Overrides:

listStatus in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

mount

public void mount(MountPRequest request,
                  io.grpc.stub.StreamObserver<MountPResponse> responseObserver)

Overrides:

mount in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

updateMount

public void updateMount(UpdateMountPRequest request,
                        io.grpc.stub.StreamObserver<UpdateMountPResponse> responseObserver)

Overrides:

updateMount in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getMountTable

public void getMountTable(GetMountTablePRequest request,
                          io.grpc.stub.StreamObserver<GetMountTablePResponse> responseObserver)

Overrides:

getMountTable in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getSyncPathList

public void getSyncPathList(GetSyncPathListPRequest request,
                            io.grpc.stub.StreamObserver<GetSyncPathListPResponse> responseObserver)

Overrides:

getSyncPathList in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

remove

public void remove(DeletePRequest request,
                   io.grpc.stub.StreamObserver<DeletePResponse> responseObserver)

Overrides:

remove in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

rename

public void rename(RenamePRequest request,
                   io.grpc.stub.StreamObserver<RenamePResponse> responseObserver)

Overrides:

rename in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

reverseResolve

public void reverseResolve(ReverseResolvePRequest request,
                           io.grpc.stub.StreamObserver<ReverseResolvePResponse> responseObserver)

Overrides:

reverseResolve in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

scheduleAsyncPersistence

public void scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request,
                                     io.grpc.stub.StreamObserver<ScheduleAsyncPersistencePResponse> responseObserver)

Overrides:

scheduleAsyncPersistence in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

setAttribute

public void setAttribute(SetAttributePRequest request,
                         io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver)

Overrides:

setAttribute in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

startSync

public void startSync(StartSyncPRequest request,
                      io.grpc.stub.StreamObserver<StartSyncPResponse> responseObserver)

Overrides:

startSync in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

stopSync

public void stopSync(StopSyncPRequest request,
                     io.grpc.stub.StreamObserver<StopSyncPResponse> responseObserver)

Overrides:

stopSync in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

unmount

public void unmount(UnmountPRequest request,
                    io.grpc.stub.StreamObserver<UnmountPResponse> responseObserver)

Overrides:

unmount in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

updateUfsMode

public void updateUfsMode(UpdateUfsModePRequest request,
                          io.grpc.stub.StreamObserver<UpdateUfsModePResponse> responseObserver)

Overrides:

updateUfsMode in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

setAcl

public void setAcl(SetAclPRequest request,
                   io.grpc.stub.StreamObserver<SetAclPResponse> responseObserver)

Overrides:

setAcl in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase