Skip navigation links
A C D G H I K L O P S T 

A

amazonKinesis() - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 

C

Checkpoint() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
cloudWatch() - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
createConsumerEndpoint(ConsumerDestination, String, ExtendedConsumerProperties<KinesisConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
createProducerMessageHandler(ProducerDestination, ExtendedProducerProperties<KinesisProducerProperties>, MessageChannel) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 

D

dynamoDB() - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
dynamoDBLockRegistry(AmazonDynamoDBAsync) - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
dynamoDBStreams() - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 

G

getAmazonKinesis() - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
getBindings() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
getCheckpoint() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
getCheckpointInterval() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getCheckpointMode() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getConsumer() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBindingProperties
 
getConsumerBackoff() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getCreateDelay() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
getCreateRetries() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
getDefaultsPrefix() - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
getDefaultsPrefix() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
getDescribeStreamBackoff() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
getDescribeStreamRetries() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
getErrorMessageStrategy() - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
getExtendedPropertiesEntryClass() - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
getExtendedPropertiesEntryClass() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
getHeaders() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
getHeartbeatPeriod() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
getIdleBetweenPolls() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getLeaseDuration() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
getListenerMode() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getLocks() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
getMinShardCount() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
getName() - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisConsumerDestination
 
getName() - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisProducerDestination
 
getNameForPartition(int) - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisProducerDestination
 
getPartitionKey() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
getProducer() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBindingProperties
 
getReadCapacity() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
getReadCapacity() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
getRecordsLimit() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getRefreshPeriod() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
getSendTimeout() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisProducerProperties
 
getShardIteratorType() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getShards() - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisConsumerDestination
 
getShards() - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisProducerDestination
 
getSortKey() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
getSortKeyName() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
getStartTimeout() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getStreamsInUse() - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
getTable() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
getTable() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
getTimeToLive() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
getWorkerId() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
getWriteCapacity() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
getWriteCapacity() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 

H

health() - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisBinderHealthIndicator
 

I

isAutoAddShards() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
isAutoCreateStream() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
isDynamoDbStreams() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
isKplKclEnabled() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
isSync() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisProducerProperties
 

K

KinesisBinderConfiguration - Class in org.springframework.cloud.stream.binder.kinesis.config
The auto-configuration for AWS components and Spring Cloud Stream Kinesis Binder.
KinesisBinderConfiguration(KinesisBinderConfigurationProperties, AWSCredentialsProvider, RegionProvider, List<Bindable>) - Constructor for class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
KinesisBinderConfiguration.KinesisBinderHealthIndicatorConfiguration - Class in org.springframework.cloud.stream.binder.kinesis.config
 
KinesisBinderConfigurationProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties
The Kinesis Binder specific configuration properties.
KinesisBinderConfigurationProperties() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
KinesisBinderConfigurationProperties.Checkpoint - Class in org.springframework.cloud.stream.binder.kinesis.properties
The checkpoint DynamoDB table configuration properties.
KinesisBinderConfigurationProperties.Locks - Class in org.springframework.cloud.stream.binder.kinesis.properties
The locks DynamoDB table configuration properties.
kinesisBinderHealthIndicator(KinesisMessageChannelBinder) - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration.KinesisBinderHealthIndicatorConfiguration
 
KinesisBinderHealthIndicator - Class in org.springframework.cloud.stream.binder.kinesis
 
KinesisBinderHealthIndicator(KinesisMessageChannelBinder) - Constructor for class org.springframework.cloud.stream.binder.kinesis.KinesisBinderHealthIndicator
 
KinesisBinderHealthIndicatorConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration.KinesisBinderHealthIndicatorConfiguration
 
KinesisBindingProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties
The Kinesis-specific binding configuration properties.
KinesisBindingProperties() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBindingProperties
 
kinesisCheckpointStore(AmazonDynamoDBAsync) - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
KinesisConsumerDestination - Class in org.springframework.cloud.stream.binder.kinesis.provisioning
The Kinesis-specific ConsumerDestination implementation.
KinesisConsumerDestination(String, List<Shard>) - Constructor for class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisConsumerDestination
 
KinesisConsumerDestination(String, List<Shard>, String) - Constructor for class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisConsumerDestination
 
KinesisConsumerProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties
The Kinesis-specific consumer binding configuration properties.
KinesisConsumerProperties() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
KinesisExtendedBindingProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties
The extended Kinesis-specific binding configuration properties.
KinesisExtendedBindingProperties() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
kinesisMessageChannelBinder(KinesisStreamProvisioner, AmazonKinesisAsync, KinesisExtendedBindingProperties, ConcurrentMetadataStore, LockRegistry, AmazonDynamoDB, AmazonDynamoDBStreams, AmazonCloudWatch, KinesisProducerConfiguration, ProducerMessageHandlerCustomizer<? extends AbstractAwsMessageHandler<Void>>, ConsumerEndpointCustomizer<? extends MessageProducerSupport>, List<KinesisClientLibConfiguration>) - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
KinesisMessageChannelBinder - Class in org.springframework.cloud.stream.binder.kinesis
The Spring Cloud Stream Binder implementation for AWS Kinesis.
KinesisMessageChannelBinder(KinesisBinderConfigurationProperties, KinesisStreamProvisioner, AmazonKinesisAsync, AWSCredentialsProvider, AmazonDynamoDB, AmazonDynamoDBStreams, AmazonCloudWatch) - Constructor for class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
kinesisProducerConfiguration() - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
KinesisProducerDestination - Class in org.springframework.cloud.stream.binder.kinesis.provisioning
The Kinesis-specific ProducerDestination implementation.
KinesisProducerProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties
The Kinesis-specific producer binding configuration properties.
KinesisProducerProperties() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisProducerProperties
 
KinesisStreamProvisioner - Class in org.springframework.cloud.stream.binder.kinesis.provisioning
The ProvisioningProvider implementation for Amazon Kinesis.
KinesisStreamProvisioner(AmazonKinesis, KinesisBinderConfigurationProperties) - Constructor for class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisStreamProvisioner
 

L

Locks() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 

O

onInit() - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
org.springframework.cloud.stream.binder.kinesis - package org.springframework.cloud.stream.binder.kinesis
 
org.springframework.cloud.stream.binder.kinesis.config - package org.springframework.cloud.stream.binder.kinesis.config
 
org.springframework.cloud.stream.binder.kinesis.properties - package org.springframework.cloud.stream.binder.kinesis.properties
 
org.springframework.cloud.stream.binder.kinesis.provisioning - package org.springframework.cloud.stream.binder.kinesis.provisioning
 

P

postProcessOutputChannel(MessageChannel, ExtendedProducerProperties<KinesisProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
provisionConsumerDestination(String, String, ExtendedConsumerProperties<KinesisConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisStreamProvisioner
 
provisioningProvider(AmazonKinesisAsync) - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
provisionProducerDestination(String, ExtendedProducerProperties<KinesisProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisStreamProvisioner
 

S

setAutoAddShards(boolean) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
setAutoCreateStream(boolean) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
setBindings(Map<String, KinesisBindingProperties>) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
setCheckpointInterval(Long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setCheckpointMode(CheckpointMode) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setCheckpointStore(ConcurrentMetadataStore) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
setConsumer(KinesisConsumerProperties) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBindingProperties
 
setConsumerBackoff(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setCreateDelay(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
setCreateRetries(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
setDescribeStreamBackoff(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
setDescribeStreamRetries(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
setDynamoDbStreams(boolean) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setExtendedBindingProperties(KinesisExtendedBindingProperties) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
setHeaders(String...) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
setHeartbeatPeriod(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setIdleBetweenPolls(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setKinesisClientLibConfigurations(List<KinesisClientLibConfiguration>) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
setKinesisProducerConfiguration(KinesisProducerConfiguration) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
setKplKclEnabled(boolean) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
setLeaseDuration(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setListenerMode(ListenerMode) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setLockRegistry(LockRegistry) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
setMinShardCount(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
setPartitionKey(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setProducer(KinesisProducerProperties) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBindingProperties
 
setReadCapacity(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
setReadCapacity(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setRecordsLimit(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setRefreshPeriod(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setSendTimeout(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisProducerProperties
 
setShardIteratorType(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setSortKey(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setSortKeyName(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setStartTimeout(int) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setSync(boolean) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisProducerProperties
 
setTable(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
setTable(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setTimeToLive(Integer) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
setWorkerId(String) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
setWriteCapacity(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint
 
setWriteCapacity(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 

T

toString() - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisConsumerDestination
 
toString() - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisProducerDestination
 
A C D G H I K L O P S T 
Skip navigation links

Copyright © 2020 Pivotal Software, Inc.. All rights reserved.