Package org.apache.nifi.util

Class MockControllerServiceInitializationContext

java.lang.Object

org.apache.nifi.util.MockControllerServiceLookup

org.apache.nifi.util.MockControllerServiceInitializationContext

All Implemented Interfaces:

org.apache.nifi.controller.ControllerServiceInitializationContext, org.apache.nifi.controller.ControllerServiceLookup, org.apache.nifi.controller.NodeTypeProvider, org.apache.nifi.kerberos.KerberosContext

public class MockControllerServiceInitializationContext
extends MockControllerServiceLookup
implements org.apache.nifi.controller.ControllerServiceInitializationContext, org.apache.nifi.controller.ControllerServiceLookup, org.apache.nifi.controller.NodeTypeProvider

Field Summary

Fields

Modifier and Type	Field	Description
private final String	identifier
private boolean	isClustered
private boolean	isPrimaryNode
private final org.apache.nifi.kerberos.KerberosContext	kerberosContext
private final org.apache.nifi.logging.ComponentLog	logger
private final org.apache.nifi.components.state.StateManager	stateManager

Constructor Summary

Constructors

Constructor	Description
MockControllerServiceInitializationContext(org.apache.nifi.controller.ControllerService controllerService, String identifier)
MockControllerServiceInitializationContext(org.apache.nifi.controller.ControllerService controllerService, String identifier, org.apache.nifi.components.state.StateManager stateManager)
MockControllerServiceInitializationContext(org.apache.nifi.controller.ControllerService controllerService, String identifier, org.apache.nifi.logging.ComponentLog logger, org.apache.nifi.components.state.StateManager stateManager)
MockControllerServiceInitializationContext(org.apache.nifi.controller.ControllerService controllerService, String identifier, org.apache.nifi.logging.ComponentLog logger, org.apache.nifi.components.state.StateManager stateManager, org.apache.nifi.kerberos.KerberosContext kerberosContext)

Method Summary

Modifier and Type	Method	Description
org.apache.nifi.controller.ControllerServiceLookup	getControllerServiceLookup()
String	getControllerServiceName(String serviceIdentifier)
String	getIdentifier()
File	getKerberosConfigurationFile()
File	getKerberosServiceKeytab()
String	getKerberosServicePrincipal()
org.apache.nifi.logging.ComponentLog	getLogger()
org.apache.nifi.controller.NodeTypeProvider	getNodeTypeProvider()
org.apache.nifi.components.state.StateManager	getStateManager()
boolean	isClustered()
boolean	isPrimary()
void	setClustered(boolean clustered)
void	setPrimaryNode(boolean primaryNode)

Methods inherited from class org.apache.nifi.util.MockControllerServiceLookup

addControllerService, addControllerService, addControllerServices, getConfiguration, getControllerService, getControllerServiceIdentifiers, getControllerServices, getInputRequirement, isControllerServiceEnabled, isControllerServiceEnabled, isControllerServiceEnabling, removeControllerService

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.controller.ControllerServiceLookup

getControllerService, getControllerServiceIdentifiers, isControllerServiceEnabled, isControllerServiceEnabled, isControllerServiceEnabling

Methods inherited from interface org.apache.nifi.controller.NodeTypeProvider

getClusterMembers, getCurrentNode, isConfiguredForClustering, isConnected

Field Details

identifier

private final String identifier

logger

private final org.apache.nifi.logging.ComponentLog logger

stateManager

private final org.apache.nifi.components.state.StateManager stateManager

isClustered

private volatile boolean isClustered

isPrimaryNode

private volatile boolean isPrimaryNode

kerberosContext

private final org.apache.nifi.kerberos.KerberosContext kerberosContext

Constructor Details

MockControllerServiceInitializationContext

public MockControllerServiceInitializationContext(org.apache.nifi.controller.ControllerService controllerService,
 String identifier)

MockControllerServiceInitializationContext

public MockControllerServiceInitializationContext(org.apache.nifi.controller.ControllerService controllerService,
 String identifier,
 org.apache.nifi.components.state.StateManager stateManager)

MockControllerServiceInitializationContext

public MockControllerServiceInitializationContext(org.apache.nifi.controller.ControllerService controllerService,
 String identifier,
 org.apache.nifi.logging.ComponentLog logger,
 org.apache.nifi.components.state.StateManager stateManager)

MockControllerServiceInitializationContext

public MockControllerServiceInitializationContext(org.apache.nifi.controller.ControllerService controllerService,
 String identifier,
 org.apache.nifi.logging.ComponentLog logger,
 org.apache.nifi.components.state.StateManager stateManager,
 org.apache.nifi.kerberos.KerberosContext kerberosContext)

Method Details

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in interface org.apache.nifi.controller.ControllerServiceInitializationContext

getControllerServiceName

public String getControllerServiceName(String serviceIdentifier)

Specified by:

getControllerServiceName in interface org.apache.nifi.controller.ControllerServiceLookup

Overrides:

getControllerServiceName in class MockControllerServiceLookup

getControllerServiceLookup

public org.apache.nifi.controller.ControllerServiceLookup getControllerServiceLookup()

Specified by:

getControllerServiceLookup in interface org.apache.nifi.controller.ControllerServiceInitializationContext

getLogger

public org.apache.nifi.logging.ComponentLog getLogger()

Specified by:

getLogger in interface org.apache.nifi.controller.ControllerServiceInitializationContext

getStateManager

public org.apache.nifi.components.state.StateManager getStateManager()

Specified by:

getStateManager in interface org.apache.nifi.controller.ControllerServiceInitializationContext

getNodeTypeProvider

public org.apache.nifi.controller.NodeTypeProvider getNodeTypeProvider()

Specified by:

getNodeTypeProvider in interface org.apache.nifi.controller.ControllerServiceInitializationContext

getKerberosServicePrincipal

public String getKerberosServicePrincipal()

Specified by:

getKerberosServicePrincipal in interface org.apache.nifi.kerberos.KerberosContext

getKerberosServiceKeytab

public File getKerberosServiceKeytab()

Specified by:

getKerberosServiceKeytab in interface org.apache.nifi.kerberos.KerberosContext

getKerberosConfigurationFile

public File getKerberosConfigurationFile()

Specified by:

getKerberosConfigurationFile in interface org.apache.nifi.kerberos.KerberosContext

isClustered

public boolean isClustered()

Specified by:

isClustered in interface org.apache.nifi.controller.NodeTypeProvider

isPrimary

public boolean isPrimary()

Specified by:

isPrimary in interface org.apache.nifi.controller.NodeTypeProvider

setClustered

public void setClustered(boolean clustered)

setPrimaryNode

public void setPrimaryNode(boolean primaryNode)