Uses of Interface
org.yamcs.yarch.StreamSubscriber

Packages that use StreamSubscriber

Package	Description
org.yamcs.archive
org.yamcs.cfdp
org.yamcs.cmdhistory
org.yamcs.http.api
org.yamcs.http.websocket
org.yamcs.parameterarchive
org.yamcs.replication
org.yamcs.tctm
org.yamcs.tctm.cfs
org.yamcs.yarch
org.yamcs.yarch.rocksdb
org.yamcs.yarch.streamsql

Uses of StreamSubscriber in org.yamcs.archive

Subinterfaces of StreamSubscriber in org.yamcs.archive

Modifier and Type	Interface	Description
interface	TmIndexService	Interface for (completeness) TmIndex.

Classes in org.yamcs.archive that implement StreamSubscriber

Modifier and Type	Class	Description
class	CcsdsTmIndex	Completeness index of CCSDS telemetry.
class	IndexServer	Deprecated.
class	YarchReplay	Performs a replay from Yarch So far supported are: TM packets, PP groups, Events, Parameters and Command History.

Uses of StreamSubscriber in org.yamcs.cfdp

Classes in org.yamcs.cfdp that implement StreamSubscriber

Modifier and Type	Class	Description
class	CfdpService	Implements CCSDS File Delivery Protocol (CFDP) in Yamcs.

Uses of StreamSubscriber in org.yamcs.cmdhistory

Classes in org.yamcs.cmdhistory that implement StreamSubscriber

Modifier and Type	Class	Description
class	StreamCommandHistoryProvider	provides command history from streams

Uses of StreamSubscriber in org.yamcs.http.api

Methods in org.yamcs.http.api with parameters of type StreamSubscriber

Modifier and Type	Method	Description
static void	StreamFactory.stream(String instance, String selectSql, List<Object> args, StreamSubscriber subscriber)
static void	StreamFactory.stream(String instance, String selectSql, StreamSubscriber subscriber)

Uses of StreamSubscriber in org.yamcs.http.websocket

Classes in org.yamcs.http.websocket that implement StreamSubscriber

Modifier and Type	Class	Description
class	StreamResource	Capable of producing and consuming yarch Stream data (Tuples) over web socket

Uses of StreamSubscriber in org.yamcs.parameterarchive

Classes in org.yamcs.parameterarchive that implement StreamSubscriber

Modifier and Type	Class	Description
class	BackFiller	Back-fills the parameter archive by triggering replays: - either regularly scheduled replays - or monitor data streams (tm, param) and keep track of which segments have to be rebuild

Uses of StreamSubscriber in org.yamcs.replication

Classes in org.yamcs.replication that implement StreamSubscriber

Modifier and Type	Class	Description
class	StreamWriter

Uses of StreamSubscriber in org.yamcs.tctm

Classes in org.yamcs.tctm that implement StreamSubscriber

Modifier and Type	Class	Description
class	StreamParameterProvider	Provides parameters from yarch streams (pp_realtime) to ParameterRequestManager.

Uses of StreamSubscriber in org.yamcs.tctm.cfs

Classes in org.yamcs.tctm.cfs that implement StreamSubscriber

Modifier and Type	Class	Description
class	CfsEventDecoder	Generate Yamcs events out of cFS event packets

Uses of StreamSubscriber in org.yamcs.yarch

Classes in org.yamcs.yarch that implement StreamSubscriber

Modifier and Type	Class	Description
class	MergeStream
class	OutputStream
class	SelectStream
class	SpeedLimitStream
class	TableWriter

Fields in org.yamcs.yarch with type parameters of type StreamSubscriber

Modifier and Type	Field	Description
protected Collection<StreamSubscriber>	Stream.subscribers

Methods in org.yamcs.yarch that return types with arguments of type StreamSubscriber

Modifier and Type	Method	Description
Collection<StreamSubscriber>	Stream.getSubscribers()

Methods in org.yamcs.yarch with parameters of type StreamSubscriber

Modifier and Type	Method	Description
void	Stream.addSubscriber(StreamSubscriber s)
void	Stream.ExceptionHandler.handle(Tuple tuple, StreamSubscriber s, Throwable t)
void	Stream.removeSubscriber(StreamSubscriber s)

Uses of StreamSubscriber in org.yamcs.yarch.rocksdb

Classes in org.yamcs.yarch.rocksdb that implement StreamSubscriber

Modifier and Type	Class	Description
class	RdbTableWriter	table writer that prepends the partition binary value in front of the key

Uses of StreamSubscriber in org.yamcs.yarch.streamsql

Classes in org.yamcs.yarch.streamsql that implement StreamSubscriber

Modifier and Type	Class	Description
class	LimitedStream