Index

B C D G I J L N O P R S T V
All Classes and Interfaces|All Packages

B

beforeDestroy() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration.ReaperTask

C

CSV - Enum constant in enum class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties.Format

csv.

D

datasetSinkMessageHandler(JdbcTemplate, PlatformTransactionManager) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration

DEFAULT_EXPRESSION - Static variable in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

Default SpEL expression.

DefaultInitializationScriptResource - Class in org.springframework.cloud.stream.app.pgcopy.sink

An in-memory script crafted for dropping-creating the table we're working with.

DefaultInitializationScriptResource(String, Collection<String>) - Constructor for class org.springframework.cloud.stream.app.pgcopy.sink.DefaultInitializationScriptResource

G

getBatchSize() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getColumns() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getDefaultOutputBinding() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

getDelimiter() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getDestinationMappings() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

getErrorTable() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getEscape() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getExpression() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

getFormat() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getIdleTimeout() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getInitialize() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getLanguage() - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

getMessageCount() - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

getMessageSize() - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

getNullString() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getProducers() - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

getQuote() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getRefreshDelay() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

getReportEveryMs() - Method in class org.springframework.cloud.stream.app.sink.throughput.ThroughputSinkProperties

getScript() - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorProperties

getScript() - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

getScript() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

getTableName() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

getVariables() - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorProperties

getVariables() - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

getVariables() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

getVariablesLocation() - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorProperties

getVariablesLocation() - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

getVariablesLocation() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

GroovyProcessorConfiguration - Class in org.springframework.cloud.stream.app.processor.groovy

A Processor app that transforms messages using a Groovy script.

GroovyProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorConfiguration

groovyProcessorFunction(ScriptVariableGenerator) - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorConfiguration

GroovyProcessorProperties - Class in org.springframework.cloud.stream.app.processor.groovy

Configuration properties for the Groovy Transform Processor module.

GroovyProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorProperties

I

isExpressionOrScriptValid() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

isGenerateTimestamp() - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

isResolutionRequired() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

J

jdbcTemplate(DataSource) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration

L

loadGeneratorEndpoint() - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceConfiguration

LoadGeneratorSourceConfiguration - Class in org.springframework.cloud.stream.app.source.load.generator

A source that sends a set amount of empty byte array messages to verify the speed of the infrastructure.

LoadGeneratorSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceConfiguration

LoadGeneratorSourceProperties - Class in org.springframework.cloud.stream.app.source.load.generator

Holds configuration options for the LoadGenerator source.

LoadGeneratorSourceProperties() - Constructor for class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

loadGeneratorSupplier() - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceConfiguration

N

nonBootDataSourceInitializer(DataSource, ResourceLoader) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration

O

org.springframework.cloud.stream.app.pgcopy.sink - package org.springframework.cloud.stream.app.pgcopy.sink

org.springframework.cloud.stream.app.processor.groovy - package org.springframework.cloud.stream.app.processor.groovy

org.springframework.cloud.stream.app.processor.script - package org.springframework.cloud.stream.app.processor.script

org.springframework.cloud.stream.app.sink.router - package org.springframework.cloud.stream.app.sink.router

org.springframework.cloud.stream.app.sink.throughput - package org.springframework.cloud.stream.app.sink.throughput

org.springframework.cloud.stream.app.source.load.generator - package org.springframework.cloud.stream.app.source.load.generator

P

pgcopyConsumer(MessageHandler) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration

PgcopySinkConfiguration - Class in org.springframework.cloud.stream.app.pgcopy.sink

Configuration class for the PostgreSQL CopyManager.

PgcopySinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration

PgcopySinkConfiguration.ReaperTask - Class in org.springframework.cloud.stream.app.pgcopy.sink

PgcopySinkProperties - Class in org.springframework.cloud.stream.app.pgcopy.sink

Used to configure the pgcopy sink module options that are related to writing using the PostgreSQL CopyManager API.

PgcopySinkProperties() - Constructor for class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

PgcopySinkProperties.Format - Enum Class in org.springframework.cloud.stream.app.pgcopy.sink

processor() - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorConfiguration

R

reap() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration.ReaperTask

ReaperTask() - Constructor for class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration.ReaperTask

router(BindingService, StreamBridge, MessageProcessor<?>) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkConfiguration

RouterSinkConfiguration - Class in org.springframework.cloud.stream.app.sink.router

A sink app that routes to one or more named channels.

RouterSinkConfiguration(RouterSinkProperties) - Constructor for class org.springframework.cloud.stream.app.sink.router.RouterSinkConfiguration

routerSinkConsumer(AbstractMessageRouter) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkConfiguration

RouterSinkProperties - Class in org.springframework.cloud.stream.app.sink.router

Properties for the Router Sink; the router can use an expression or groovy script to return either a channel name, or a key to the channel mappings map.

RouterSinkProperties() - Constructor for class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

S

scriptProcessor() - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkConfiguration

ScriptProcessorConfiguration - Class in org.springframework.cloud.stream.app.processor.script

A Processor module that transforms messages using a supplied script.

ScriptProcessorConfiguration(ScriptProcessorProperties, ScriptVariableGenerator) - Constructor for class org.springframework.cloud.stream.app.processor.script.ScriptProcessorConfiguration

scriptProcessorFunction(MessageProcessor<?>) - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorConfiguration

ScriptProcessorProperties - Class in org.springframework.cloud.stream.app.processor.script

Configuration properties for the Scriptable Transform Processor module.

ScriptProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

scriptVariableGenerator() - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorConfiguration

scriptVariableGenerator() - Method in class org.springframework.cloud.stream.app.processor.script.ScriptVariableGeneratorConfiguration

ScriptVariableGeneratorConfiguration - Class in org.springframework.cloud.stream.app.processor.script

Configuration that provides a ScriptVariableGenerator to customize a script.

ScriptVariableGeneratorConfiguration() - Constructor for class org.springframework.cloud.stream.app.processor.script.ScriptVariableGeneratorConfiguration

setBatchSize(int) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setColumns(List<String>) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setDefaultOutputBinding(String) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

setDelimiter(String) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setDestinationMappings(Properties) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

setErrorTable(String) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setEscape(Character) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setExpression(Expression) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

setFormat(PgcopySinkProperties.Format) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setGenerateTimestamp(boolean) - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

setIdleTimeout(long) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setInitialize(String) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setLanguage(String) - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

setMessageCount(int) - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

setMessageSize(int) - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

setNullString(String) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setProducers(int) - Method in class org.springframework.cloud.stream.app.source.load.generator.LoadGeneratorSourceProperties

setQuote(Character) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setRefreshDelay(int) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

setReportEveryMs(int) - Method in class org.springframework.cloud.stream.app.sink.throughput.ThroughputSinkProperties

setResolutionRequired(boolean) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

setScript(String) - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

setScript(Resource) - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorProperties

setScript(Resource) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

setTableName(String) - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties

setVariables(Properties) - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorProperties

setVariables(Properties) - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

setVariables(Properties) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

setVariablesLocation(Resource) - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorProperties

setVariablesLocation(Resource) - Method in class org.springframework.cloud.stream.app.processor.script.ScriptProcessorProperties

setVariablesLocation(Resource) - Method in class org.springframework.cloud.stream.app.sink.router.RouterSinkProperties

T

TEXT - Enum constant in enum class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties.Format

text.

throughputConsumer() - Method in class org.springframework.cloud.stream.app.sink.throughput.ThroughputSinkConfiguration

ThroughputSinkConfiguration - Class in org.springframework.cloud.stream.app.sink.throughput

ThroughputSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.sink.throughput.ThroughputSinkConfiguration

ThroughputSinkProperties - Class in org.springframework.cloud.stream.app.sink.throughput

Holds configuration options for the throughput Sink.

ThroughputSinkProperties() - Constructor for class org.springframework.cloud.stream.app.sink.throughput.ThroughputSinkProperties

toSink() - Method in class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration

transformer(ScriptVariableGenerator) - Method in class org.springframework.cloud.stream.app.processor.groovy.GroovyProcessorConfiguration

V

valueOf(String) - Static method in enum class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties.Format

Returns the enum constant of this class with the specified name.

values() - Static method in enum class org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties.Format

Returns an array containing the constants of this enum class, in the order they are declared.

B C D G I J L N O P R S T V
All Classes and Interfaces|All Packages