Elasticsearch Transport-Netty3 Plugin

import org.elasticsearch.transport.Netty3Plugin;
import org.elasticsearch.transport.netty3.Netty3Transport;
import org.elasticsearch.http.netty3.Netty3HttpServerTransport;

// Plugin registration (handled automatically by Elasticsearch)
// The plugin provides "netty3" transport implementations

// Configuration in elasticsearch.yml
// transport.type: netty3
// http.type: netty3

// Programmatic access to transport instances
Settings settings = Settings.builder()
    .put("transport.type", "netty3")
    .put("http.type", "netty3")
    .build();

// Plugin provides transport factories through NetworkPlugin interface
Netty3Plugin plugin = new Netty3Plugin();
List<Setting<?>> pluginSettings = plugin.getSettings();

public class Netty3Plugin extends Plugin implements NetworkPlugin {
    public static final String NETTY_TRANSPORT_NAME = "netty3";
    public static final String NETTY_HTTP_TRANSPORT_NAME = "netty3";
    
    public List<Setting<?>> getSettings();
    public Map<String, Supplier<Transport>> getTransports(
        Settings settings, ThreadPool threadPool, BigArrays bigArrays,
        CircuitBreakerService circuitBreakerService,
        NamedWriteableRegistry namedWriteableRegistry, 
        NetworkService networkService
    );
    public Map<String, Supplier<HttpServerTransport>> getHttpTransports(
        Settings settings, ThreadPool threadPool, BigArrays bigArrays,
        CircuitBreakerService circuitBreakerService,
        NamedWriteableRegistry namedWriteableRegistry,
        NamedXContentRegistry xContentRegistry,
        NetworkService networkService,
        HttpServerTransport.Dispatcher dispatcher
    );
}

public class Netty3Transport extends TcpTransport<Channel> {
    public static final Setting<Integer> WORKER_COUNT;
    public static final Setting<ByteSizeValue> NETTY_MAX_CUMULATION_BUFFER_CAPACITY;
    public static final Setting<Integer> NETTY_MAX_COMPOSITE_BUFFER_COMPONENTS;
    
    public Netty3Transport(Settings settings, ThreadPool threadPool, 
                          NetworkService networkService, BigArrays bigArrays,
                          NamedWriteableRegistry namedWriteableRegistry, 
                          CircuitBreakerService circuitBreakerService);
    public long serverOpen();
    public ChannelPipelineFactory configureClientChannelPipelineFactory();
    public ChannelPipelineFactory configureServerChannelPipelineFactory(String name, Settings settings);
}

public class Netty3HttpServerTransport extends AbstractLifecycleComponent 
                                       implements HttpServerTransport {
    public static final Setting<ByteSizeValue> SETTING_HTTP_NETTY_MAX_CUMULATION_BUFFER_CAPACITY;
    public static final Setting<Integer> SETTING_HTTP_WORKER_COUNT;
    public static final Setting<Boolean> SETTING_HTTP_TCP_NO_DELAY;
    
    public Netty3HttpServerTransport(Settings settings, NetworkService networkService,
                                   BigArrays bigArrays, ThreadPool threadPool,
                                   NamedXContentRegistry xContentRegistry,
                                   HttpServerTransport.Dispatcher dispatcher);
    public Settings settings();
    public BoundTransportAddress boundAddress();
    public HttpInfo info();
    public HttpStats stats();
    public Netty3CorsConfig getCorsConfig();
}

public class Netty3Utils {
    public static final boolean DEFAULT_GATHERING = true;
    
    public static void setup();
    public static ChannelBuffer toChannelBuffer(BytesReference bytes);
    public static BytesReference toBytesReference(ChannelBuffer buffer);
    public static BytesReference toBytesReference(ChannelBuffer buffer, int size);
    public static void closeChannels(Collection<Channel> channels);
    public static void maybeDie(Throwable t);
}

public class Netty3CorsConfig {
    public boolean isCorsSupportEnabled();
    public boolean isAnyOriginSupported();
    public Set<String> origins();
    public boolean isOriginAllowed(String origin);
    public boolean isCredentialsAllowed();
    public long maxAge();
    public Set<HttpMethod> allowedRequestMethods();
    public Set<String> allowedRequestHeaders();
}

public class Netty3CorsConfigBuilder {
    public static Netty3CorsConfigBuilder forAnyOrigin();
    public static Netty3CorsConfigBuilder forOrigin(String origin);
    public Netty3CorsConfigBuilder allowCredentials();
    public Netty3CorsConfigBuilder maxAge(long maxAge);
    public Netty3CorsConfig build();
}

public final class Netty3HttpChannel extends AbstractRestChannel {
    public Netty3HttpChannel(Netty3HttpServerTransport transport, Netty3HttpRequest request,
                           OrderedUpstreamMessageEvent orderedUpstreamMessageEvent,
                           boolean detailedErrorsEnabled, ThreadContext threadContext);
    public BytesStreamOutput newBytesOutput();
    public void sendResponse(RestResponse response);
}

public class Netty3HttpRequest extends RestRequest {
    public Netty3HttpRequest(NamedXContentRegistry xContentRegistry, HttpRequest request, Channel channel);
    public HttpRequest request();
    public Method method();
    public String uri();
    public boolean hasContent();
    public BytesReference content();
    public SocketAddress getRemoteAddress();
    public SocketAddress getLocalAddress();
    public Channel getChannel();
}

public class HttpPipeliningHandler extends SimpleChannelHandler {
    public static final int INITIAL_EVENTS_HELD = 3;
    public HttpPipeliningHandler(int maxEventsHeld);
    public void handleUpstream(ChannelHandlerContext ctx, ChannelEvent e);
    public void handleDownstream(ChannelHandlerContext ctx, ChannelEvent e);
}