Uses of Interface
org.apache.storm.messaging.IContext

Packages that use IContext

Package	Description
org.apache.storm.daemon.supervisor
org.apache.storm.daemon.worker
org.apache.storm.messaging
org.apache.storm.messaging.local

Uses of IContext in org.apache.storm.daemon.supervisor

Methods in org.apache.storm.daemon.supervisor with parameters of type IContext

Modifier and Type	Method and Description
static ContainerLauncher	ContainerLauncher.make(Map<String,Object> conf, String supervisorId, int supervisorPort, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker) Factory to create the right container launcher for the config and the environment.

Constructors in org.apache.storm.daemon.supervisor with parameters of type IContext

Constructor and Description
LocalContainer(Map<String,Object> conf, String supervisorId, int supervisorPort, int port, LocalAssignment assignment, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker)
LocalContainerLauncher(Map<String,Object> conf, String supervisorId, int supervisorPort, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker)
Supervisor(Map<String,Object> conf, IContext sharedContext, ISupervisor iSupervisor, StormMetricsRegistry metricsRegistry) Constructor for supervisor daemon.

Uses of IContext in org.apache.storm.daemon.worker

Constructors in org.apache.storm.daemon.worker with parameters of type IContext

Constructor and Description
Worker(Map<String,Object> conf, IContext context, String topologyId, String assignmentId, int supervisorPort, int port, String workerId) TODO: should worker even take the topologyId as input? this should be deducible from cluster state (by searching through assignments) what about if there’s inconsistency in assignments? -> but nimbus should guarantee this consistency.
WorkerState(Map<String,Object> conf, IContext mqContext, String topologyId, String assignmentId, int supervisorPort, int port, String workerId, Map<String,Object> topologyConf, IStateStorage stateStorage, IStormClusterState stormClusterState, Collection<IAutoCredentials> autoCredentials)

Uses of IContext in org.apache.storm.messaging

Methods in org.apache.storm.messaging that return IContext

Modifier and Type	Method and Description
static IContext	TransportFactory.makeContext(Map<String,Object> topoConf)

Uses of IContext in org.apache.storm.messaging.local

Classes in org.apache.storm.messaging.local that implement IContext

Modifier and Type	Class and Description
class	Context