io.micronaut.http.netty.channel

Class KQueueEventLoopGroupFactory

java.lang.Object

io.micronaut.http.netty.channel.KQueueEventLoopGroupFactory

All Implemented Interfaces:

EventLoopGroupFactory

@Singleton
 @Internal
 @Requires(classes=io.netty.channel.kqueue.KQueue.class,
          condition=KQueueAvailabilityCondition.class)
 @Named(value="native")
public class KQueueEventLoopGroupFactory
extends java.lang.Object
implements EventLoopGroupFactory

Factory for KQueueEventLoopGroup.

Author:

croudet

Field Summary

Fields inherited from interface io.micronaut.http.netty.channel.EventLoopGroupFactory

NATIVE

Constructor Summary

Constructors

Constructor and Description
KQueueEventLoopGroupFactory()

Method Summary

Modifier and Type	Method and Description
java.lang.Class<? extends io.netty.channel.socket.SocketChannel>	clientSocketChannelClass(EventLoopGroupConfiguration configuration) Returns the client channel class.
io.netty.channel.EventLoopGroup	createEventLoopGroup(java.lang.Integer ioRatio) Creates a default KQueueEventLoopGroup.
io.netty.channel.EventLoopGroup	createEventLoopGroup(int threads, java.util.concurrent.Executor executor, java.lang.Integer ioRatio) Creates a KQueueEventLoopGroup.
io.netty.channel.EventLoopGroup	createEventLoopGroup(int threads, java.lang.Integer ioRatio) Creates a KQueueEventLoopGroup.
io.netty.channel.EventLoopGroup	createEventLoopGroup(int threads, java.util.concurrent.ThreadFactory threadFactory, java.lang.Integer ioRatio) Creates a KQueueEventLoopGroup.
boolean	isNative()
java.lang.Class<? extends io.netty.channel.socket.ServerSocketChannel>	serverSocketChannelClass() Returns the server channel class.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.http.netty.channel.EventLoopGroupFactory

createEventLoopGroup, serverSocketChannelClass

Constructor Detail

KQueueEventLoopGroupFactory

public KQueueEventLoopGroupFactory()

Method Detail

createEventLoopGroup

public io.netty.channel.EventLoopGroup createEventLoopGroup(int threads,
                                                            @Nullable
                                                            java.lang.Integer ioRatio)

Creates a KQueueEventLoopGroup.

Specified by:

createEventLoopGroup in interface EventLoopGroupFactory

Parameters:

threads - The number of threads to use.

ioRatio - The io ratio.

Returns:

A KQueueEventLoopGroup.

createEventLoopGroup

public io.netty.channel.EventLoopGroup createEventLoopGroup(int threads,
                                                            java.util.concurrent.ThreadFactory threadFactory,
                                                            @Nullable
                                                            java.lang.Integer ioRatio)

Creates a KQueueEventLoopGroup.

Specified by:

createEventLoopGroup in interface EventLoopGroupFactory

Parameters:

threads - The number of threads to use.

threadFactory - The thread factory.

ioRatio - The io ratio.

Returns:

A KQueueEventLoopGroup.

createEventLoopGroup

public io.netty.channel.EventLoopGroup createEventLoopGroup(int threads,
                                                            java.util.concurrent.Executor executor,
                                                            @Nullable
                                                            java.lang.Integer ioRatio)

Creates a KQueueEventLoopGroup.

Specified by:

createEventLoopGroup in interface EventLoopGroupFactory

Parameters:

threads - The number of threads to use.

executor - An Executor.

ioRatio - The io ratio.

Returns:

A KQueueEventLoopGroup.

createEventLoopGroup

public io.netty.channel.EventLoopGroup createEventLoopGroup(@Nullable
                                                            java.lang.Integer ioRatio)

Creates a default KQueueEventLoopGroup.

Specified by:

createEventLoopGroup in interface EventLoopGroupFactory

Parameters:

ioRatio - The io ratio.

Returns:

A KQueueEventLoopGroup.

isNative

public boolean isNative()

Specified by:

isNative in interface EventLoopGroupFactory

Returns:

Is this a native factory.

serverSocketChannelClass

public java.lang.Class<? extends io.netty.channel.socket.ServerSocketChannel> serverSocketChannelClass()

Returns the server channel class.

Specified by:

serverSocketChannelClass in interface EventLoopGroupFactory

Returns:

KQueueServerSocketChannel.

clientSocketChannelClass

@NonNull
public java.lang.Class<? extends io.netty.channel.socket.SocketChannel> clientSocketChannelClass(@Nullable
                                                                                                          EventLoopGroupConfiguration configuration)

Description copied from interface: EventLoopGroupFactory

Returns the client channel class.

Specified by:

clientSocketChannelClass in interface EventLoopGroupFactory

Parameters:

configuration - The configuration

Returns:

A SocketChannel.