alluxio.security.authentication

Class SaslStreamServerDriver

java.lang.Object

alluxio.security.authentication.SaslStreamServerDriver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<SaslMessage>

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

Responsible for driving sasl traffic from server-side. Acts as a server's Sasl stream.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close() Closes the authentication stream.
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

SaslStreamServerDriver

public SaslStreamServerDriver(AuthenticationServer authenticationServer)

Creates SaslStreamServerDriver 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()

Closes the authentication stream.