Package com.helix.core.stream.disruptor

Class DisruptorConfig

java.lang.Object

com.helix.core.stream.disruptor.DisruptorConfig

public class DisruptorConfig
extends Object

Configuration options for the LMAX Disruptor streaming engine.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DisruptorConfig.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_RING_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
DisruptorConfig(int ringBufferSize, com.lmax.disruptor.WaitStrategy waitStrategy, com.lmax.disruptor.dsl.ProducerType producerType, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
static DisruptorConfig.Builder	builder()
static DisruptorConfig	defaultConfig()
com.lmax.disruptor.dsl.ProducerType	getProducerType()
int	getRingBufferSize()
ThreadFactory	getThreadFactory()
com.lmax.disruptor.WaitStrategy	getWaitStrategy()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_RING_BUFFER_SIZE

public static final int DEFAULT_RING_BUFFER_SIZE

See Also:

• Constant Field Values

Constructor Details

DisruptorConfig

public DisruptorConfig(int ringBufferSize,
 com.lmax.disruptor.WaitStrategy waitStrategy,
 com.lmax.disruptor.dsl.ProducerType producerType,
 ThreadFactory threadFactory)

Method Details

defaultConfig

public static DisruptorConfig defaultConfig()

builder

public static DisruptorConfig.Builder builder()

getRingBufferSize

public int getRingBufferSize()

getWaitStrategy

public com.lmax.disruptor.WaitStrategy getWaitStrategy()

getProducerType

public com.lmax.disruptor.dsl.ProducerType getProducerType()

getThreadFactory

public ThreadFactory getThreadFactory()