Package com.illumon.iris.controller

Class InWorkerServiceControllerConfigurationProcessor

java.lang.Object

com.illumon.iris.controller.InWorkerServiceControllerConfigurationProcessor

All Implemented Interfaces:

ControllerConfigurationProcessor

public class InWorkerServiceControllerConfigurationProcessor
extends Object
implements ControllerConfigurationProcessor

Controller migration class to update DATA_SERVICES_SCRIPT persistent queries to use the new InWorkerServiceSetupQuery.IN_WORKER_SERVICE_CONFIG_TYPE query type.

Constructor Summary

Constructors

Constructor	Description
InWorkerServiceControllerConfigurationProcessor()

Method Summary

Modifier and Type	Method	Description
boolean	apply(com.fishlib.io.logger.Logger log, PqStorage pqStorage, AtomicLong nextSerial)	Apply the in-worker service persistent query changes to the controller's hash table.

Methods inherited from class java.lang.Object

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

Constructor Details

InWorkerServiceControllerConfigurationProcessor

public InWorkerServiceControllerConfigurationProcessor()

Method Details

apply

public boolean apply(@NotNull
 com.fishlib.io.logger.Logger log,
 PqStorage pqStorage,
 @NotNull
 AtomicLong nextSerial)
              throws PqStorageException

Apply the in-worker service persistent query changes to the controller's hash table. This implementation takes any existing DATA_SERVICES_SCRIPT query types and converts them to InWorkerServiceSetupQuery.IN_WORKER_SERVICE_CONFIG_TYPE configurations.

Specified by:

apply in interface ControllerConfigurationProcessor

Parameters:

log - a Logger instance

pqStorage - the controller's PQ storage provider

nextSerial - the next available serial

Returns:

true if any changes were made, false otherwise

Throws:

PqStorageException