Package io.jenkins.plugins.aws.kinesisconsumer
-
Interface Summary Interface Description KinesisConsumer.Factory KinesisRecordProcessor.Factory -
Class Summary Class Description GlobalKinesisConfiguration Class representing the Global Kinesis configurationKinesisConsumer Responsible to connect to the configured Kinesis streams and start the scheduler threads to begin polling recordsKinesisConsumerManager Manager of stream connectionsKinesisConsumerModule KinesisRecordProcessor Implements theShardRecordProcessor
interface to process data records fetched from Amazon KinesisKinesisRecordProcessorFactory Factory to createKinesisRecordProcessor
instances.KinesisStreamItem Class representing a Stream configurationKinesisStreamItem.DescriptorImpl SaveableListenerImpl ExtendsSaveableListener
to listen toGlobalKinesisConfiguration
changes.