OpflowRestrictor (opflow-core 0.1.27 API)

java.lang.Object

com.devebot.opflow.OpflowRestrictor

All Implemented Interfaces:: AutoCloseable

public class OpflowRestrictor
extends Object
implements AutoCloseable

Author:: pnhung177

Nested Class Summary

Nested Classes

Modifier and Type Class Description

static interface OpflowRestrictor.Action<T>

Constructor Summary

Constructors
Constructor	Description
`OpflowRestrictor()`
`OpflowRestrictor(ReentrantReadWriteLock sharedLock, Map<String,Object> options)`
`OpflowRestrictor(Map<String,Object> options)`

Method Summary

Modifier and Type	Method	Description
`void`	`close()`
`<T> T`	`filter(OpflowRestrictor.Action<T> action)`
`String`	`getInstanceId()`
`long`	`getPauseDuration()`
`long`	`getPauseElapsed()`
`long`	`getPauseTimeout()`
`int`	`getSemaphoreLimit()`
`int`	`getSemaphorePermits()`
`long`	`getSemaphoreTimeout()`
`boolean`	`isActive()`
`boolean`	`isPaused()`
`boolean`	`isPauseEnabled()`
`boolean`	`isSemaphoreEnabled()`
`void`	`lock()`
`Map<String,Object>`	`pause(long duration)`
`void`	`setActive(boolean enabled)`
`void`	`unlock()`
`Map<String,Object>`	`unpause()`

Methods inherited from class java.lang.Object

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

Constructor Details
- OpflowRestrictor
  
  public OpflowRestrictor()
- OpflowRestrictor
  
  public OpflowRestrictor(Map<String,Object> options)
- OpflowRestrictor
  
  public OpflowRestrictor(ReentrantReadWriteLock sharedLock, Map<String,Object> options)
Method Details
- isActive
  
  public boolean isActive()
- setActive
  
  public void setActive(boolean enabled)
- getInstanceId
  
  public String getInstanceId()
- isPauseEnabled
  
  public boolean isPauseEnabled()
- getPauseTimeout
  
  public long getPauseTimeout()
- getPauseDuration
  
  public long getPauseDuration()
- getPauseElapsed
  
  public long getPauseElapsed()
- getSemaphoreLimit
  
  public int getSemaphoreLimit()
- getSemaphorePermits
  
  public int getSemaphorePermits()
- isSemaphoreEnabled
  
  public boolean isSemaphoreEnabled()
- getSemaphoreTimeout
  
  public long getSemaphoreTimeout()
- filter
  
  public <T> T filter(OpflowRestrictor.Action<T> action) throws Throwable
  
  Throws:
  
  Throwable
- isPaused
  
  public boolean isPaused()
- pause
  
  public Map<String,Object> pause(long duration)
- unpause
  
  public Map<String,Object> unpause()
- lock
  
  public void lock()
- unlock
  
  public void unlock()
- close
  
  public void close()
  
  Specified by:
  
  close in interface AutoCloseable