Package org.nuxeo.lib.stream.computation

Interface StreamManager

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

LogStreamManager

public interface StreamManager
extends AutoCloseable

Gives access to StreamProcessor and appender for source provider.

Since:

11.1

Method Summary

Modifier and Type	Method	Description
LogOffset	append(String stream, Record record)	Appends a record to a processor's source stream.
void	close()
StreamProcessor	createStreamProcessor(String processorName)	Creates a registered processor without starting it.
StreamProcessor	getProcessor(String processorName)	Gets a processor.
Set<String>	getProcessorNames()	Gets a set of processor names.
void	register(String processorName, Topology topology, Settings settings)	Registers a processor and initializes the underlying streams, this is needed before creating a processor or appending record in source streams.
void	register(List<String> streams, Settings settings)	Registers some source Streams without any processors.
default StreamProcessor	registerAndCreateProcessor(String processorName, Topology topology, Settings settings)	Registers and creates a processor without starting it.
boolean	waitFor(String stream, Name group, LogOffset offset, Duration timeout)	Wait for a consumer group to process the stream up to the given offset.

Method Details

register

void register(String processorName,
 Topology topology,
 Settings settings)

Registers a processor and initializes the underlying streams, this is needed before creating a processor or appending record in source streams.

createStreamProcessor

StreamProcessor createStreamProcessor(String processorName)

Creates a registered processor without starting it.

registerAndCreateProcessor

default StreamProcessor registerAndCreateProcessor(String processorName,
 Topology topology,
 Settings settings)

Registers and creates a processor without starting it.

register

void register(List<String> streams,
 Settings settings)

Registers some source Streams without any processors.

Since:

11.4

append

LogOffset append(String stream,
 Record record)

Appends a record to a processor's source stream.

waitFor

boolean waitFor(String stream,
 Name group,
 LogOffset offset,
 Duration timeout)
         throws InterruptedException

Wait for a consumer group to process the stream up to the given offset.

Throws:

InterruptedException

Since:

2025.0

getProcessorNames

Set<String> getProcessorNames()

Gets a set of processor names.

Since:

2021.25

getProcessor

StreamProcessor getProcessor(String processorName)

Gets a processor.

Returns:

null if the processor doesn't exist

Since:

2021.25

close

void close()

Specified by:

close in interface AutoCloseable