alluxio.worker.grpc

Class GrpcDataServer

java.lang.Object

alluxio.worker.grpc.GrpcDataServer

All Implemented Interfaces:

DataServer, Closeable, AutoCloseable

@NotThreadSafe
public class GrpcDataServer
extends Object
implements DataServer

Runs a gRPC data server that responds to block requests.

Constructor Summary

Constructors

Constructor and Description
GrpcDataServer(String hostName, SocketAddress bindAddress, BlockWorkerGrpc.BlockWorkerImplBase blockWorkerService) Creates a new instance of GrpcDataServer.

Method Summary

Modifier and Type	Method and Description
void	awaitTermination() Waits for server to terminate.
void	close()
protected GrpcServerBuilder	createServerBuilder(String hostName, SocketAddress bindAddress, ChannelType type)
SocketAddress	getBindAddress() Gets the actual bind socket address.
SocketAddress	getS3BindAddress() Gets the actual bind socket address for S3.
boolean	isClosed() Checks if the DataServer is closed.

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcDataServer

public GrpcDataServer(String hostName,
                      SocketAddress bindAddress,
                      BlockWorkerGrpc.BlockWorkerImplBase blockWorkerService)

Creates a new instance of GrpcDataServer.

Parameters:

hostName - the server host name

bindAddress - the server bind address

blockWorkerService - the instance of BlockWorkerGrpc.BlockWorkerImplBase

Method Detail

createServerBuilder

protected GrpcServerBuilder createServerBuilder(String hostName,
                                                SocketAddress bindAddress,
                                                ChannelType type)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getBindAddress

public SocketAddress getBindAddress()

Description copied from interface: DataServer

Gets the actual bind socket address. It is either a InetSocketAddress or a DomainSocketAddress.

Specified by:

getBindAddress in interface DataServer

Returns:

the bind socket address

getS3BindAddress

public SocketAddress getS3BindAddress()

Description copied from interface: DataServer

Gets the actual bind socket address for S3. It is either a InetSocketAddress or a DomainSocketAddress.

Specified by:

getS3BindAddress in interface DataServer

Returns:

the bind socket address

isClosed

public boolean isClosed()

Description copied from interface: DataServer

Checks if the DataServer is closed.

Specified by:

isClosed in interface DataServer

Returns:

true if the DataServer is closed, false otherwise

awaitTermination

public void awaitTermination()

Description copied from interface: DataServer

Waits for server to terminate.

Specified by:

awaitTermination in interface DataServer