org.tikv.common.util

Class ChannelFactory

java.lang.Object

org.tikv.common.util.ChannelFactory

All Implemented Interfaces:

AutoCloseable

public class ChannelFactory
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ChannelFactory.CertContext
static class	ChannelFactory.CertWatcher
static class	ChannelFactory.JksContext
static class	ChannelFactory.OpenSslContext

Field Summary

Fields

Modifier and Type	Field and Description
ConcurrentHashMap<String,io.grpc.ManagedChannel>	connPool

Constructor Summary

Constructors

Constructor and Description
ChannelFactory(int maxFrameSize, int keepaliveTime, int keepaliveTimeout, int idleTimeout)
ChannelFactory(int maxFrameSize, int keepaliveTime, int keepaliveTimeout, int idleTimeout, long connRecycleTime, long certReloadInterval, String trustCertCollectionFilePath, String keyCertChainFilePath, String keyFilePath)
ChannelFactory(int maxFrameSize, int keepaliveTime, int keepaliveTimeout, int idleTimeout, long connRecycleTime, long certReloadInterval, String jksKeyPath, String jksKeyPassword, String jksTrustPath, String jksTrustPassword)

Method Summary

Modifier and Type	Method and Description
void	close()
io.grpc.ManagedChannel	getChannel(String address, HostMapping mapping)

Methods inherited from class java.lang.Object

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

Field Detail

connPool

public final ConcurrentHashMap<String,io.grpc.ManagedChannel> connPool

Constructor Detail

ChannelFactory

public ChannelFactory(int maxFrameSize,
                      int keepaliveTime,
                      int keepaliveTimeout,
                      int idleTimeout)

ChannelFactory

public ChannelFactory(int maxFrameSize,
                      int keepaliveTime,
                      int keepaliveTimeout,
                      int idleTimeout,
                      long connRecycleTime,
                      long certReloadInterval,
                      String trustCertCollectionFilePath,
                      String keyCertChainFilePath,
                      String keyFilePath)

ChannelFactory

public ChannelFactory(int maxFrameSize,
                      int keepaliveTime,
                      int keepaliveTimeout,
                      int idleTimeout,
                      long connRecycleTime,
                      long certReloadInterval,
                      String jksKeyPath,
                      String jksKeyPassword,
                      String jksTrustPath,
                      String jksTrustPassword)

Method Detail

getChannel

public io.grpc.ManagedChannel getChannel(String address,
                                         HostMapping mapping)

close

public void close()

Specified by:

close in interface AutoCloseable