C I K M O P R S

C

CloudEventInput - Class in io.streamzi.eventflow.runtime

Defines a class that can supply cloud events to a consumer method

CloudEventInput(Object, Method) - Constructor for class io.streamzi.eventflow.runtime.CloudEventInput

CloudEventOutput - Class in io.streamzi.eventflow.runtime

Variable that gets injected into a class to receive CloudEvents

CloudEventOutput(Object, String) - Constructor for class io.streamzi.eventflow.runtime.CloudEventOutput

CloudEventTimer - Class in io.streamzi.eventflow.runtime

Timed executor for method

CloudEventTimer() - Constructor for class io.streamzi.eventflow.runtime.CloudEventTimer

CloudEventTimer(Object, Method) - Constructor for class io.streamzi.eventflow.runtime.CloudEventTimer

consumerMethod - Variable in class io.streamzi.eventflow.runtime.CloudEventInput

consumerObject - Variable in class io.streamzi.eventflow.runtime.CloudEventInput

I

inputName - Variable in class io.streamzi.eventflow.runtime.CloudEventInput

io.streamzi.eventflow.runtime - package io.streamzi.eventflow.runtime

io.streamzi.eventflow.runtime.kafka - package io.streamzi.eventflow.runtime.kafka

K

KafkaCloudEventInputImpl - Class in io.streamzi.eventflow.runtime.kafka

Connects to a Kafka topic to get cloud events

KafkaCloudEventInputImpl(Object, Method) - Constructor for class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventInputImpl

KafkaCloudEventOutputImpl - Class in io.streamzi.eventflow.runtime.kafka

Cloud event output that sends data to Kafka

KafkaCloudEventOutputImpl(Object, String) - Constructor for class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventOutputImpl

M

main(String[]) - Static method in class io.streamzi.eventflow.runtime.ProcessorRunner

O

objectType - Variable in class io.streamzi.eventflow.runtime.CloudEventInput

outputName - Variable in class io.streamzi.eventflow.runtime.CloudEventOutput

P

ProcessorContainer - Class in io.streamzi.eventflow.runtime

This class holds a single processor component, checks for annotations etc

ProcessorContainer(Class) - Constructor for class io.streamzi.eventflow.runtime.ProcessorContainer

ProcessorRunner - Class in io.streamzi.eventflow.runtime

Main class that starts everything going

ProcessorRunner() - Constructor for class io.streamzi.eventflow.runtime.ProcessorRunner

processorUuid - Variable in class io.streamzi.eventflow.runtime.CloudEventInput

processorUuid - Variable in class io.streamzi.eventflow.runtime.CloudEventOutput

producerObject - Variable in class io.streamzi.eventflow.runtime.CloudEventOutput

R

run() - Method in class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventInputImpl

run() - Method in class io.streamzi.eventflow.runtime.ProcessorRunner

S

send(Object) - Method in class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventOutputImpl

send(String, Object) - Method in class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventOutputImpl

startInput() - Method in class io.streamzi.eventflow.runtime.CloudEventInput

startInput() - Method in class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventInputImpl

startOutput() - Method in class io.streamzi.eventflow.runtime.CloudEventOutput

startOutput() - Method in class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventOutputImpl

startProcessor() - Method in class io.streamzi.eventflow.runtime.ProcessorContainer

startTimer() - Method in class io.streamzi.eventflow.runtime.CloudEventTimer

stop() - Method in class io.streamzi.eventflow.runtime.ProcessorRunner

stopInput() - Method in class io.streamzi.eventflow.runtime.CloudEventInput

stopInput() - Method in class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventInputImpl

stopOutput() - Method in class io.streamzi.eventflow.runtime.CloudEventOutput

stopOutput() - Method in class io.streamzi.eventflow.runtime.kafka.KafkaCloudEventOutputImpl

stopProcessor() - Method in class io.streamzi.eventflow.runtime.ProcessorContainer

stopTimer() - Method in class io.streamzi.eventflow.runtime.CloudEventTimer

C I K M O P R S