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
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.