alluxio.security.authentication

Class AuthenticatedChannelServerDriver

java.lang.Object

alluxio.security.authentication.AuthenticatedChannelServerDriver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<SaslMessage>

public class AuthenticatedChannelServerDriver
extends Object
implements io.grpc.stub.StreamObserver<SaslMessage>

Responsible for driving authentication traffic from server-side.

Constructor Summary

Constructors

Constructor and Description
AuthenticatedChannelServerDriver(AuthenticationServer authenticationServer) Creates AuthenticatedChannelServerDriver for given AuthenticationServer.

Method Summary

Modifier and Type	Method and Description
void	close() Completes authenticated channel.
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(SaslMessage saslMessage)
void	setClientObserver(io.grpc.stub.StreamObserver<SaslMessage> requestObserver) Sets the client's Sasl stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

AuthenticatedChannelServerDriver

public AuthenticatedChannelServerDriver(AuthenticationServer authenticationServer)

Creates AuthenticatedChannelServerDriver for given AuthenticationServer.

Parameters:

authenticationServer - authentication server

Method Detail

setClientObserver

public void setClientObserver(io.grpc.stub.StreamObserver<SaslMessage> requestObserver)

Sets the client's Sasl stream.

Parameters:

requestObserver - client Sasl stream

onNext

public void onNext(SaslMessage saslMessage)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<SaslMessage>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface io.grpc.stub.StreamObserver<SaslMessage>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<SaslMessage>

close

public void close()

Completes authenticated channel.