alluxio.grpc

Class GrpcConnection

java.lang.Object

alluxio.grpc.GrpcConnection

All Implemented Interfaces:

AutoCloseable

public class GrpcConnection
extends Object
implements AutoCloseable

Used to gather gRPC level resources and indexes together.

Constructor Summary

Constructors

Constructor and Description
GrpcConnection(GrpcConnectionKey key, io.grpc.ManagedChannel managedChannel, AlluxioConfiguration conf) Creates a new connection object.

Method Summary

Modifier and Type	Method and Description
void	close() Releases the connection to the pool.
boolean	equals(Object other)
io.grpc.Channel	getChannel()
GrpcChannelKey	getChannelKey()
AlluxioConfiguration	getConfiguration()
int	hashCode()
void	interceptChannel(io.grpc.ClientInterceptor interceptor) Registers interceptor to the channel.

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcConnection

public GrpcConnection(GrpcConnectionKey key,
                      io.grpc.ManagedChannel managedChannel,
                      AlluxioConfiguration conf)

Creates a new connection object.

Parameters:

key - gRPC channel key

managedChannel - the underlying gRPC ManagedChannel

conf - the Alluxio configuration

Method Detail

getChannelKey

public GrpcChannelKey getChannelKey()

Returns:

the hannel key that owns the connection

getChannel

public io.grpc.Channel getChannel()

Returns:

the channel

interceptChannel

public void interceptChannel(io.grpc.ClientInterceptor interceptor)

Registers interceptor to the channel.

Parameters:

interceptor - the gRPC client interceptor

getConfiguration

public AlluxioConfiguration getConfiguration()

Returns:

the configuration used when the connection was established

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

close

public void close()
           throws Exception

Releases the connection to the pool.

Specified by:

close in interface AutoCloseable

Throws:

Exception - not expected