Module org.yamcs.core
Package org.yamcs.tctm

Class StreamParameterProvider

java.lang.Object
com.google.common.util.concurrent.AbstractService
org.yamcs.AbstractProcessorService
org.yamcs.tctm.StreamParameterProvider
All Implemented Interfaces:
com.google.common.util.concurrent.Service, ParameterProvider, ProcessorService, StreamSubscriber
public class StreamParameterProvider extends AbstractProcessorService implements StreamSubscriber, ParameterProvider
Provides parameters from yarch streams (pp_realtime) to ParameterProcessorManager

  • Nested Class Summary

    Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

    com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

  • Field Summary

    Fields inherited from class org.yamcs.AbstractProcessorService

    config, log, processor

  • Constructor Summary

    Constructors
    Constructor
    Description
    StreamParameterProvider()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    canProvide(org.yamcs.protobuf.Yamcs.NamedObjectId id)
    Returns whether or not a given parameter can be provided by this provider
    boolean
    canProvide(Parameter p)
     
    protected void
    doStart()
     
    protected void
    doStop()
     
    Parameter
    getParameter(org.yamcs.protobuf.Yamcs.NamedObjectId id)
    Returns the parameterDefinition corresponding to the parameter id
    void
    init(Processor processor, YConfiguration config, Object spec)
     
    void
    onTuple(Stream s, Tuple tuple)
    Make sure all parameters are defined in the XtceDB, otherwise the PRM will choke
    void
    setParameterProcessor(ParameterProcessor paraListener)
    Send parameters to this processor.
    void
    startProviding(Parameter paramDef)
    Adds a new parameter to the list of parameters that have to provided
    void
    startProvidingAll()
    start providing all known parameters
    void
    stopProviding(Parameter paramDef)
    Removes a parameter from the list of parameters that have to be provided
    void
    streamClosed(Stream s)
     

    Methods inherited from class org.yamcs.AbstractProcessorService

    getConfig, getYamcsInstance

    Methods inherited from class com.google.common.util.concurrent.AbstractService

    addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    Methods inherited from interface org.yamcs.ProcessorService

    getSpec

    Methods inherited from interface com.google.common.util.concurrent.Service

    addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync