A C D F G I K L O P S

A

AWSKinesisStreamListener - Class in io.jenkins.plugins.aws.kinesisconsumer.extensions

Extension point to implement by external applications to listen to records coming from a Kinesis stream.

AWSKinesisStreamListener() - Constructor for class io.jenkins.plugins.aws.kinesisconsumer.extensions.AWSKinesisStreamListener

C

configure(StaplerRequest, JSONObject) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

configure() - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisConsumerModule

create(GlobalKinesisConfiguration) - Method in interface io.jenkins.plugins.aws.kinesisconsumer.KinesisConsumer.Factory

create(String) - Method in interface io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor.Factory

D

DescriptorImpl() - Constructor for class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem.DescriptorImpl

doCheckInitialPositionInStream(String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Checks AWS Kinesis initial stream position is valid.

doCheckLocalEndpoint(String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Checks local endpoint URL is valid.

doCheckRegion(String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Checks AWS region is valid.

doTestConnection(String, String, String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem.DescriptorImpl

F

fireOnReceive(String, byte[]) - Static method in class io.jenkins.plugins.aws.kinesisconsumer.extensions.AWSKinesisStreamListener

G

get() - Static method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Get the GlobalKinesisConfiguration

get() - Static method in class io.jenkins.plugins.aws.kinesisconsumer.SaveableListenerImpl

Gets an instance of this extension

getAllRegisteredListeners() - Static method in class io.jenkins.plugins.aws.kinesisconsumer.extensions.AWSKinesisStreamListener

Gets all listeners.

getDescriptor() - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem

Get a Descriptor of KinesisStreamItem instance

getDisplayName() - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem.DescriptorImpl

getInitialPositionInStream() - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem

Get the initial position in the Kinesis stream Valid values are: LATEST or TRIM_HORIZON.

getKinesisStreamItems() - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

getKinesisStreamItemsForStream(String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

getLocalEndpoint() - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Get the local endpoint to consume from rather than the AWS service

getRegion() - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Get the AWS Region to connect to from the configuration page

getStreamName() - Method in class io.jenkins.plugins.aws.kinesisconsumer.extensions.AWSKinesisStreamListener

This needs to be overridden to specify which Kinesis record to listen

getStreamName() - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem

Get the stream name

GlobalKinesisConfiguration - Class in io.jenkins.plugins.aws.kinesisconsumer

Class representing the Global Kinesis configuration

GlobalKinesisConfiguration() - Constructor for class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

I

initialize(InitializationInput) - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor

io.jenkins.plugins.aws.kinesisconsumer - package io.jenkins.plugins.aws.kinesisconsumer

io.jenkins.plugins.aws.kinesisconsumer.extensions - package io.jenkins.plugins.aws.kinesisconsumer.extensions

isKinesisConsumerEnabled() - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Indicates if the plugin is enabled or not

K

KinesisConsumer - Class in io.jenkins.plugins.aws.kinesisconsumer

Responsible to connect to the configured Kinesis streams and start the scheduler threads to begin polling records

KinesisConsumer.Factory - Interface in io.jenkins.plugins.aws.kinesisconsumer

KinesisConsumerModule - Class in io.jenkins.plugins.aws.kinesisconsumer

KinesisConsumerModule() - Constructor for class io.jenkins.plugins.aws.kinesisconsumer.KinesisConsumerModule

KinesisRecordProcessor - Class in io.jenkins.plugins.aws.kinesisconsumer

Implements the ShardRecordProcessor interface to process data records fetched from Amazon Kinesis

KinesisRecordProcessor.Factory - Interface in io.jenkins.plugins.aws.kinesisconsumer

KinesisRecordProcessorFactory - Class in io.jenkins.plugins.aws.kinesisconsumer

Factory to create KinesisRecordProcessor instances.

KinesisStreamItem - Class in io.jenkins.plugins.aws.kinesisconsumer

Class representing a Stream configuration

KinesisStreamItem(String, String) - Constructor for class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem

Creates KinesisStreamItem instance.

KinesisStreamItem.DescriptorImpl - Class in io.jenkins.plugins.aws.kinesisconsumer

L

leaseLost(LeaseLostInput) - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor

O

onChange(Saveable, XmlFile) - Method in class io.jenkins.plugins.aws.kinesisconsumer.SaveableListenerImpl

On change restart the AWS Kinesis consumer.

onReceive(byte[]) - Method in class io.jenkins.plugins.aws.kinesisconsumer.extensions.AWSKinesisStreamListener

This needs to be overridden to implement the logic upon record receive

P

processRecords(ProcessRecordsInput) - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor

Forward each byte record of ProcessRecordsInput to the AWSKinesisStreamListener interface

S

SaveableListenerImpl - Class in io.jenkins.plugins.aws.kinesisconsumer

Extends SaveableListener to listen to GlobalKinesisConfiguration changes.

SaveableListenerImpl(KinesisConsumer.Factory) - Constructor for class io.jenkins.plugins.aws.kinesisconsumer.SaveableListenerImpl

SaveableListenerImpl() - Constructor for class io.jenkins.plugins.aws.kinesisconsumer.SaveableListenerImpl

setInitialPositionInStream(String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem

Set the initial position in the Kinesis stream

setKinesisConsumerEnabled(boolean) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Set the enabled/disabled status of the plugin when loading the global configuration page

setKinesisStreamItems(List<KinesisStreamItem>) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Set KinesisStreamItem values when loading the global configuration page

setLocalEndpoint(String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Set an optional endpoint to point to a local kinesis stack rather than the AWS service.

setRegion(String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.GlobalKinesisConfiguration

Set AWS Region when loading the global configuration page

setStreamName(String) - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisStreamItem

Set the stream name

shardEnded(ShardEndedInput) - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor

shardRecordProcessor() - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessorFactory

shutdown() - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisConsumer

Stop the scheduler threads to end consuming records from the Kinesis streams

shutdownRequested(ShutdownRequestedInput) - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor

start() - Method in class io.jenkins.plugins.aws.kinesisconsumer.KinesisConsumer

Starts the scheduler threads to begin polling records from the Kinesis streams configured

streamName - Variable in class io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor

A C D F G I K L O P S