A C G I K O P S T

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

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

getConsumer() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBindingProperties

getDescribeStreamBackoff() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties

getDescribeStreamRetries() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties

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

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

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

getShards() - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisConsumerDestination

getShards() - Method in class org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisProducerDestination

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

getWriteCapacity() - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint

I

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

KinesisBindingProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties

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

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

KinesisExtendedBindingProperties - Class in org.springframework.cloud.stream.binder.kinesis.properties

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

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

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

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

setBindings(Map<String, KinesisBindingProperties>) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties

setCheckpoint(KinesisBinderConfigurationProperties.Checkpoint) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties

setCheckpointStore(MetadataStore) - Method in class org.springframework.cloud.stream.binder.kinesis.KinesisMessageChannelBinder

setConsumer(KinesisConsumerProperties) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBindingProperties

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

setHeaders(String...) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties

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

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

setWriteCapacity(Long) - Method in class org.springframework.cloud.stream.binder.kinesis.properties.KinesisBinderConfigurationProperties.Checkpoint

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 G I K O P S T