com.aerospike.client.async

Class NettyEventLoops

java.lang.Object

com.aerospike.client.async.NettyEventLoops

All Implemented Interfaces:

EventLoops, io.netty.handler.ssl.CipherSuiteFilter, Closeable, AutoCloseable

public final class NettyEventLoops
extends Object
implements EventLoops, io.netty.handler.ssl.CipherSuiteFilter

Aerospike wrapper around netty event loops. Implements the Aerospike EventLoops interface.

Constructor Summary

Constructors

Constructor and Description
NettyEventLoops(io.netty.channel.EventLoopGroup group) Create Aerospike event loop wrappers from given netty event loops.
NettyEventLoops(EventPolicy policy, io.netty.channel.EventLoopGroup group) Create Aerospike event loop wrappers from given netty event loops.

Method Summary

Modifier and Type	Method and Description
void	close() Close event loops.
String[]	filterCipherSuites(Iterable<String> ciphers, List<String> defaultCiphers, Set<String> supportedCiphers) Filter cipher suites.
NettyEventLoop	get(io.netty.util.concurrent.EventExecutor eventExecutor) Return corresponding Aerospike event loop given netty event loop.
NettyEventLoop	get(int index) Return Aerospike event loop given array index..
NettyEventLoop[]	getArray() Return array of Aerospike event loops.
int	getSize() Return number of event loops in this group.
void	initTlsContext(TlsPolicy policy) Initialize TLS context.
NettyEventLoop	next() Return next Aerospike event loop in round-robin fashion.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyEventLoops

public NettyEventLoops(io.netty.channel.EventLoopGroup group)

Create Aerospike event loop wrappers from given netty event loops.

NettyEventLoops

public NettyEventLoops(EventPolicy policy,
                       io.netty.channel.EventLoopGroup group)

Create Aerospike event loop wrappers from given netty event loops.

Method Detail

initTlsContext

public void initTlsContext(TlsPolicy policy)

Initialize TLS context. For internal use only.

Specified by:

initTlsContext in interface EventLoops

filterCipherSuites

public String[] filterCipherSuites(Iterable<String> ciphers,
                                   List<String> defaultCiphers,
                                   Set<String> supportedCiphers)

Filter cipher suites. For internal use only.

Specified by:

filterCipherSuites in interface io.netty.handler.ssl.CipherSuiteFilter

get

public NettyEventLoop get(io.netty.util.concurrent.EventExecutor eventExecutor)

Return corresponding Aerospike event loop given netty event loop.

getArray

public NettyEventLoop[] getArray()

Return array of Aerospike event loops.

Specified by:

getArray in interface EventLoops

getSize

public int getSize()

Return number of event loops in this group.

Specified by:

getSize in interface EventLoops

get

public NettyEventLoop get(int index)

Return Aerospike event loop given array index..

Specified by:

get in interface EventLoops

next

public NettyEventLoop next()

Return next Aerospike event loop in round-robin fashion.

Specified by:

next in interface EventLoops

close

public void close()

Description copied from interface: EventLoops

Close event loops.

Specified by:

close in interface EventLoops

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable