com.devebot.opflow.services.OpflowRestrictorMaster

public class OpflowRestrictorMaster
extends OpflowRestrictable.Runner
implements AutoCloseable

Method Summary

append, append, filter

execute, setParent

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

Field Details
- componentId
  
  protected final String componentId
- logTracer
  
  protected final OpflowLogTracer logTracer
- measurer
  
  protected final OpflowPromMeasurer measurer
Constructor Details
- OpflowRestrictorMaster
  
  public OpflowRestrictorMaster(Map<String,Object> options)
Method Details
- getComponentId
  
  public String getComponentId()
- getValveRestrictor
  
  public OpflowRestrictor.Valve getValveRestrictor()
- isActive
  
  public boolean isActive()
- setActive
  
  public void setActive(boolean enabled)
- isBlocked
  
  public boolean isBlocked()
- block
  
  public void block()
- unblock
  
  public void unblock()
- isPauseEnabled
  
  public boolean isPauseEnabled()
- getPauseTimeout
  
  public long getPauseTimeout()
- getPauseDuration
  
  public long getPauseDuration()
- getPauseElapsed
  
  public long getPauseElapsed()
- isPaused
  
  public boolean isPaused()
- pause
  
  public Map<String,Object> pause(long duration)
- unpause
  
  public Map<String,Object> unpause()
- getSemaphoreLimit
  
  public int getSemaphoreLimit()
- getSemaphorePermits
  
  public int getSemaphorePermits()
- isSemaphoreEnabled
  
  public boolean isSemaphoreEnabled()
- getSemaphoreTimeout
  
  public long getSemaphoreTimeout()
- close
  
  public void close()
  
  Specified by:
  
  close in interface AutoCloseable

Modifier and Type	Field	Description
`protected String`	`componentId`
`protected OpflowLogTracer`	`logTracer`
`protected OpflowPromMeasurer`	`measurer`

Class OpflowRestrictorMaster