All Classes and Interfaces
Class
Description
Configuration properties for the Aggregator function.
Common properties for the cassandra modules.
The annotated String must be a valid
SimpleDateFormat pattern.An in-memory script crafted for dropping-creating the table we're working with.
An in-memory script crafted for dropping-creating the table we're working with.
Factory bean for an encoder/decoder based on
Encoding.An
EnvironmentPostProcessor to add spring.autoconfigure.exclude property
since we can't use application.properties from the library perspective.Properties for the file sink.
Defines the supported modes of reading and processing files.
Properties for the file supplier.
A Processor app that transforms messages using a Groovy script.
Configuration properties for the Groovy Transform Processor module.
Configuration properties for the Header Enricher Processor application.
Configuration for a
Function that makes HTTP requests to a resource and for
each request, returns a ResponseEntity.Function that accepts a
Flux<Message<?>> containing body and headers and
returns a Flux<ResponseEntity<?>>.Configuration properties for the Http Client Processor module.
Configuration for the HTTP Supplier.
Configuration properties for the HTTP Supplier.
Create a text file mapping label id to human readable string.
Ability to to augment the input image fromMemory the recognized labels.
A repository for
Traces.Properties for the JMS Supplier.
A source that sends a set amount of empty byte array messages to verify the speed
of the infrastructure.
Holds configuration options for the LoadGenerator source.
The Configuration class for
Consumer which logs incoming data.Configuration properties for the Log Sink app.
Mail supplier components.
Properties for the file supplier.
A configuration for MongoDB Consumer function.
A configuration for MongoDB Source applications.
Generic mqtt configuration.
A consumer that sends data to Mqtt.
Properties for the Mqtt Consumer.
Generic mqtt connection properties.
A source module that receives data from Mqtt.
Properties for the Mqtt Source.
Augment the input image fromMemory detected object bounding boxes and categories.
Converts byte array image into a input Tensor for the Object Detection API.
Converts byte array image into a input Tensor for the Object Detection API.
Converts the Tensorflow Object Detection result into
ObjectDetection list.Convenience class that leverages the the
ObjectDetectionInputConverter, ObjectDetectionOutputConverter and TensorFlowService
in combination fromMemory the Tensorflow Object Detection API (https://github.com/tensorflow/models/tree/master/research/object_detection)
models for detection objects in input images.Configuration class for the PostgreSQL CopyManager.
Used to configure the pgcopy sink module options that are related to writing using the PostgreSQL CopyManager API.
A configuration for RabbitMQ Consumer function.
A source module that receives data from RabbitMQ.
Used to configure those Redis Sink module options that are not related to connecting to Redis.
A
MessageSourceMutator that deletes a remote file on success.A
MessageSourceMutator that renames a remote file on success.A sink app that routes to one or more named channels.
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.
A Processor module that transforms messages using a supplied script.
Configuration properties for the Scriptable Transform Processor module.
Configuration that provides a
ScriptVariableGenerator to customize a script.Searched tweets are ordered from top to bottom by their IDs.
Configuration for SFTP Consumer.
Session factory configuration.
Session factory configuration.
An
RotatingServerAdvice for listing files on multiple directories/servers.A Converter from String to Map that accepts csv key:value pairs
(similar to what comes out of the box in Spring Core) but also simple
key items, in which case the value is assumed to be equal to the key.
Configuration properties for the SpEL function.
Configuration properties for the Splitter Processor app.
Protobuf type
org.springframework.cloud.fn.object.detection.protos.StringIntLabelMapProtobuf type
org.springframework.cloud.fn.object.detection.protos.StringIntLabelMapProtobuf type
org.springframework.cloud.fn.object.detection.protos.StringIntLabelMapItemProtobuf type
org.springframework.cloud.fn.object.detection.protos.StringIntLabelMapItemConfiguration class for SYSLOG Supplier.
A marker interface useful for unambiguous dependency injection of this Function.
Configuration for a
TaskLaunchRequestFunction, provided as a common function that can be composed with other Suppliers or
Functions to transform any Message to a TaskLaunchRequest which may be used as input to the TaskLauncherFunction to launch a task.Base Properties to create a
TaskLaunchRequest.Base class for TCP connection factory properties.
A consumer that sends data over TCP.
Properties for the TCP Consumer.
A source module that receives data over TCP.
Properties for the TCP Source.
Holds configuration options for the throughput Sink.
A value object representing a trace event: at a particular time with a simple (map)
information.
Search pagination with max_id and since_id: https://developer.twitter.com/en/docs/tweets/timelines/guides/working-with-timelines.html .
Bootstraps a Netty server using the
WebsocketConsumerServerInitializer.Handles handshakes and messages.
Does some basic initialization and setup.
Simple Spring Boot Actuator
Endpoint implementation that
provides access to Websocket messages last sent/received.A supplier that receives data over WebSocket.
Configuration properties available for Websocket Supplier.
A source module that receives data from ZeroMQ.
A source module that receives data from ZeroMQ.