Package org.graylog.integrations.aws.transports

Class KinesisTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.ThrottleableTransport

org.graylog2.plugin.inputs.transports.ThrottleableTransport2

org.graylog.integrations.aws.transports.KinesisTransport

All Implemented Interfaces:

Transport

public class KinesisTransport
extends ThrottleableTransport2

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KinesisTransport.Config
static interface	KinesisTransport.Factory

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CK_KINESIS_RECORD_BATCH_SIZE
static final String	CK_KINESIS_STREAM_NAME
static final int	DEFAULT_BATCH_SIZE
static final String	NAME

Fields inherited from class org.graylog2.plugin.inputs.transports.ThrottleableTransport

CK_THROTTLING_ALLOWED, eventBus, throttlingAllowed

Constructor Summary

Constructors

Constructor	Description
KinesisTransport(Configuration configuration, com.google.common.eventbus.EventBus serverEventBus, NodeId nodeId, LocalMetricRegistry localRegistry, com.fasterxml.jackson.databind.ObjectMapper objectMapper, AWSClientBuilderUtil awsClientBuilderUtil)

Method Summary

Modifier and Type	Method	Description
void	doLaunch(MessageInput input, InputFailureRecorder inputFailureRecorder)
void	doStop()	Performs the same purpose as ThrottleableTransport.stop() but guarantees that the superclass' actions are performed.
com.codahale.metrics.MetricSet	getMetricSet()
void	handleChangedThrottledState(boolean isThrottled)	Transports can override this to be notified when the throttled state changes.
void	setMessageAggregator(CodecAggregator aggregator)

Methods inherited from class org.graylog2.plugin.inputs.transports.ThrottleableTransport2

doLaunch, launch

Methods inherited from class org.graylog2.plugin.inputs.transports.ThrottleableTransport

blockUntilUnthrottled, blockUntilUnthrottled, determineIfThrottled, isThrottled, launch, stop, updateThrottleState

Methods inherited from class java.lang.Object

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

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

CK_KINESIS_STREAM_NAME

public static final String CK_KINESIS_STREAM_NAME

See Also:

• Constant Field Values

CK_KINESIS_RECORD_BATCH_SIZE

public static final String CK_KINESIS_RECORD_BATCH_SIZE

See Also:

• Constant Field Values

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

• Constant Field Values

Constructor Details

KinesisTransport

@Inject
public KinesisTransport(Configuration configuration,
 com.google.common.eventbus.EventBus serverEventBus,
 NodeId nodeId,
 LocalMetricRegistry localRegistry,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 AWSClientBuilderUtil awsClientBuilderUtil)

Method Details

handleChangedThrottledState

public void handleChangedThrottledState(boolean isThrottled)

Description copied from class: ThrottleableTransport

Transports can override this to be notified when the throttled state changes. Only called when throttled state changes.

Overrides:

handleChangedThrottledState in class ThrottleableTransport

Parameters:

isThrottled - the current throttled state.

doLaunch

public void doLaunch(MessageInput input,
 InputFailureRecorder inputFailureRecorder)
              throws MisfireException

Specified by:

doLaunch in class ThrottleableTransport2

Throws:

MisfireException

doStop

public void doStop()

Description copied from class: ThrottleableTransport

Performs the same purpose as ThrottleableTransport.stop() but guarantees that the superclass' actions are performed.

Specified by:

doStop in class ThrottleableTransport

setMessageAggregator

public void setMessageAggregator(CodecAggregator aggregator)

getMetricSet

public com.codahale.metrics.MetricSet getMetricSet()