alluxio.grpc

Class PolicyMasterClientServiceGrpc.PolicyMasterClientServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<PolicyMasterClientServiceGrpc.PolicyMasterClientServiceStub>

alluxio.grpc.PolicyMasterClientServiceGrpc.PolicyMasterClientServiceStub

Enclosing class:

PolicyMasterClientServiceGrpc

public static final class PolicyMasterClientServiceGrpc.PolicyMasterClientServiceStub
extends io.grpc.stub.AbstractAsyncStub<PolicyMasterClientServiceGrpc.PolicyMasterClientServiceStub>

A stub to allow clients to do asynchronous rpc calls to service PolicyMasterClientService.

 This interface contains policy master service endpoints for Alluxio clients.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
void	addPolicy(AddPolicyPRequest request, io.grpc.stub.StreamObserver<AddPolicyPResponse> responseObserver) Adds a new policy definition
protected PolicyMasterClientServiceGrpc.PolicyMasterClientServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	getActionInfo(GetActionInfoRequest request, io.grpc.stub.StreamObserver<GetActionInfoResponse> responseObserver) Gets the information of a action
void	getPolicyStatus(GetPolicyStatusPRequest request, io.grpc.stub.StreamObserver<GetPolicyStatusPResponse> responseObserver) Gets the status of a policy
void	listPolicy(ListPolicyPRequest request, io.grpc.stub.StreamObserver<ListPolicyPResponse> responseObserver) Returns the list of policies
void	removePolicy(RemovePolicyPRequest request, io.grpc.stub.StreamObserver<RemovePolicyPResponse> responseObserver) Removes a policy definition
void	triggerPolicy(TriggerPolicyRequest request, io.grpc.stub.StreamObserver<TriggerPolicyResponse> responseObserver) Trigger policy scan for all policies

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected PolicyMasterClientServiceGrpc.PolicyMasterClientServiceStub build(io.grpc.Channel channel,
                                                                            io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<PolicyMasterClientServiceGrpc.PolicyMasterClientServiceStub>

listPolicy

public void listPolicy(ListPolicyPRequest request,
                       io.grpc.stub.StreamObserver<ListPolicyPResponse> responseObserver)

 Returns the list of policies
 

addPolicy

public void addPolicy(AddPolicyPRequest request,
                      io.grpc.stub.StreamObserver<AddPolicyPResponse> responseObserver)

 Adds a new policy definition
 

removePolicy

public void removePolicy(RemovePolicyPRequest request,
                         io.grpc.stub.StreamObserver<RemovePolicyPResponse> responseObserver)

 Removes a policy definition
 

getPolicyStatus

public void getPolicyStatus(GetPolicyStatusPRequest request,
                            io.grpc.stub.StreamObserver<GetPolicyStatusPResponse> responseObserver)

 Gets the status of a policy
 

getActionInfo

public void getActionInfo(GetActionInfoRequest request,
                          io.grpc.stub.StreamObserver<GetActionInfoResponse> responseObserver)

 Gets the information of a action
 

triggerPolicy

public void triggerPolicy(TriggerPolicyRequest request,
                          io.grpc.stub.StreamObserver<TriggerPolicyResponse> responseObserver)

 Trigger policy scan for all policies