Class ReplicationSlave

java.lang.Object
com.google.common.util.concurrent.AbstractService
org.yamcs.AbstractYamcsService
org.yamcs.replication.ReplicationSlave
All Implemented Interfaces:
com.google.common.util.concurrent.Service, YamcsService

public class ReplicationSlave extends AbstractYamcsService
  • Constructor Details

    • ReplicationSlave

      public ReplicationSlave()
  • Method Details

    • init

      public void init(String yamcsInstance, String serviceName, YConfiguration config) throws InitException
      Description copied from interface: YamcsService
      Initialize this service. This is called before the service is started. All operations should finish fast.
      Specified by:
      init in interface YamcsService
      Overrides:
      init in class AbstractYamcsService
      Parameters:
      yamcsInstance - The yamcs instance, or null if this is a global service.
      serviceName - The service name.
      config - The configured arguments for this service. If YamcsService.getSpec() is implemented then this contains the arguments after being validated (including any defaults).
      Throws:
      InitException - When something goes wrong during the execution of this method.
    • getSpec

      public Spec getSpec()
      Description copied from interface: YamcsService
      Returns the valid configuration options for this service.
      Returns:
      the argument specification, or null if the args should not be validated.
    • doStart

      protected void doStart()
      Specified by:
      doStart in class com.google.common.util.concurrent.AbstractService
    • doStop

      protected void doStop()
      Specified by:
      doStop in class com.google.common.util.concurrent.AbstractService
    • getStreamNames

      public List<String> getStreamNames()
    • isTcpClient

      public boolean isTcpClient()
    • getTcpClient

      public ReplicationClient getTcpClient()
    • getMasterHost

      public String getMasterHost()
    • getMasterPort

      public int getMasterPort()
    • getMasterInstance

      public String getMasterInstance()
    • getTxId

      public long getTxId()
    • newChannelHandler

      public io.netty.channel.ChannelHandler newChannelHandler() throws YamcsException
      Called when the tcpRole = Server and a new client connects to ReplicationServer
      Throws:
      YamcsException - if there is already a connection open to this slave