Package com.linkedin.venice.controller.spark

Class VeniceSparkEmbeddedJettyServer

java.lang.Object

com.linkedin.venice.controller.spark.VeniceSparkEmbeddedJettyServer

All Implemented Interfaces:

spark.embeddedserver.EmbeddedServer

public class VeniceSparkEmbeddedJettyServer
extends Object
implements spark.embeddedserver.EmbeddedServer

Spark server implementation

Constructor Summary

Constructors

Constructor	Description
VeniceSparkEmbeddedJettyServer(VeniceProperties jettyConfigOverrides, org.eclipse.jetty.server.Handler handler)

Method Summary

Modifier and Type	Method	Description
int	activeThreadCount()
void	configureWebSockets(Map<String,spark.embeddedserver.jetty.websocket.WebSocketHandlerWrapper> webSocketHandlers, Optional<Long> webSocketIdleTimeoutMillis)
void	extinguish()
int	ignite(String host, int port, spark.ssl.SslStores sslStores, int maxThreads, int minThreads, int threadIdleTimeoutMillis)
void	join()
void	trustForwardHeaders(boolean trust)
VeniceSparkEmbeddedJettyServer	withThreadPool(org.eclipse.jetty.util.thread.ThreadPool threadPool)	Sets optional thread pool for jetty server.

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceSparkEmbeddedJettyServer

public VeniceSparkEmbeddedJettyServer(VeniceProperties jettyConfigOverrides,
 org.eclipse.jetty.server.Handler handler)

Method Details

configureWebSockets

public void configureWebSockets(Map<String,spark.embeddedserver.jetty.websocket.WebSocketHandlerWrapper> webSocketHandlers,
 Optional<Long> webSocketIdleTimeoutMillis)

Specified by:

configureWebSockets in interface spark.embeddedserver.EmbeddedServer

trustForwardHeaders

public void trustForwardHeaders(boolean trust)

Specified by:

trustForwardHeaders in interface spark.embeddedserver.EmbeddedServer

ignite

public int ignite(String host,
 int port,
 spark.ssl.SslStores sslStores,
 int maxThreads,
 int minThreads,
 int threadIdleTimeoutMillis)
           throws Exception

Specified by:

ignite in interface spark.embeddedserver.EmbeddedServer

Throws:

Exception

join

public void join()
          throws InterruptedException

Specified by:

join in interface spark.embeddedserver.EmbeddedServer

Throws:

InterruptedException

extinguish

public void extinguish()

Specified by:

extinguish in interface spark.embeddedserver.EmbeddedServer

activeThreadCount

public int activeThreadCount()

Specified by:

activeThreadCount in interface spark.embeddedserver.EmbeddedServer

withThreadPool

public VeniceSparkEmbeddedJettyServer withThreadPool(org.eclipse.jetty.util.thread.ThreadPool threadPool)

Sets optional thread pool for jetty server. This is useful for overriding the default thread pool behaviour for example io.dropwizard.metrics.jetty9.InstrumentedQueuedThreadPool.

Parameters:

threadPool - thread pool

Returns:

Builder pattern - returns this instance