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

A

amazonKinesis(AWSCredentialsProvider, RegionProvider) - 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
 
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(AWSCredentialsProvider, RegionProvider) - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
dynamoDBLockRegistry(AmazonDynamoDBAsync) - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 

G

getBindings() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
getCheckpoint() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
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
 
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
 
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
 
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
 
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
 

I

isAutoAddShards() - 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
 
KinesisBinderConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
KinesisBinderConfigurationProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties
 
KinesisBinderConfigurationProperties() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties
 
KinesisBinderConfigurationProperties.Checkpoint - Class in org.springframework.cloud.stream.binder.kinesis.properties
 
KinesisBinderConfigurationProperties.Locks - Class in org.springframework.cloud.stream.binder.kinesis.properties
 
KinesisBindingProperties - Class in org.springframework.cloud.stream.binder.kinesis.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
 
KinesisConsumerProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties
 
KinesisConsumerProperties() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties
 
KinesisConsumerProperties.KinesisListenerMode - Enum in org.springframework.cloud.stream.binder.kinesis.properties
 
KinesisExtendedBindingProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties
 
KinesisExtendedBindingProperties() - Constructor for class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
kinesisMessageChannelBinder(AmazonKinesisAsync, KinesisStreamProvisioner, ConcurrentMetadataStore, LockRegistry, KinesisExtendedBindingProperties) - Method in class org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration
 
KinesisMessageChannelBinder - Class in org.springframework.cloud.stream.binder.kinesis
 
KinesisMessageChannelBinder(AmazonKinesisAsync, KinesisBinderConfigurationProperties, KinesisStreamProvisioner) - Constructor for class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder
 
KinesisProducerDestination - Class in org.springframework.cloud.stream.binder.kinesis.provisioning
 
KinesisProducerProperties - Class in org.springframework.cloud.stream.binder.kinesis.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

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
 
setBindings(Map<String, KinesisBindingProperties>) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties
 
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
 
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
 
setLeaseDuration(long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Locks
 
setListenerMode(KinesisConsumerProperties.KinesisListenerMode) - 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
 
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
 

V

valueOf(String) - Static method in enum org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties.KinesisListenerMode
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.cloud.stream.binder.kinesis.properties.KinesisConsumerProperties.KinesisListenerMode
Returns an array containing the constants of this enum type, in the order they are declared.
A C D G I K L O P S T V 
Skip navigation links

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