Class FilibusterCore
- java.lang.Object
-
- cloud.filibuster.junit.server.core.FilibusterCore
-
public class FilibusterCore extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description FilibusterCore(FilibusterConfiguration filibusterConfiguration)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
analysisFile(org.json.JSONObject analysisFile)
org.json.JSONObject
beginInvocation(org.json.JSONObject payload)
void
completeIteration(int currentIteration)
void
completeIteration(int currentIteration, int exceptionOccurred, java.lang.Throwable throwable)
void
completeIteration(int currentIteration, int exceptionOccurred, java.lang.Throwable throwable, boolean shouldPrintRpcSummary)
void
disableFaultInjection()
void
enableFaultInjection()
org.json.JSONObject
endInvocation(org.json.JSONObject payload, boolean isUpdate)
java.util.Map<DistributedExecutionIndex,org.json.JSONObject>
executedRpcs()
java.util.Map<DistributedExecutionIndex,org.json.JSONObject>
failedRpcs()
java.util.Map<DistributedExecutionIndex,org.json.JSONObject>
faultsInjected()
static FilibusterCore
getCurrentInstance()
BlockType
getLastTestScopeBlockType()
static TestExecutionReport
getMostRecentInitialTestExecutionReport()
int
getNumBypassedExecutions()
int
getTestScopeCounter()
static boolean
hasCurrentInstance()
boolean
hasNextIteration(int currentIteration)
boolean
hasNextIteration(int currentIteration, java.lang.String caller)
void
incrementTestScopeCounter()
void
incrementTestScopeCounter(BlockType blockType)
boolean
isNewTestExecution(java.lang.String serviceName)
int
iterationsRemaining()
static void
removeCurrentInstance()
static void
setMostRecentInitialTestExecutionReport(TestExecutionReport report)
void
teardownsCompleted(int currentIteration)
void
terminateFilibuster()
boolean
testContainsOrganicFailures()
boolean
wasFaultInjected()
boolean
wasFaultInjectedOnHttpMethod(com.linecorp.armeria.common.HttpMethod httpMethod, java.lang.String uriPattern)
boolean
wasFaultInjectedOnHttpRequest(com.linecorp.armeria.common.HttpMethod httpMethod, java.lang.String uriPattern, java.lang.String serializedRequestPattern)
boolean
wasFaultInjectedOnMethod(java.lang.String serviceName, java.lang.String methodName)
boolean
wasFaultInjectedOnMethodWhereRequestContains(java.lang.String serviceName, java.lang.String methodName, java.lang.String contains)
boolean
wasFaultInjectedOnRequest(java.lang.String serializedRequest)
boolean
wasFaultInjectedOnService(java.lang.String serviceName)
void
writePlaceholderReport()
-
-
-
Constructor Detail
-
FilibusterCore
public FilibusterCore(FilibusterConfiguration filibusterConfiguration)
-
-
Method Detail
-
getCurrentInstance
public static FilibusterCore getCurrentInstance()
-
hasCurrentInstance
public static boolean hasCurrentInstance()
-
getNumBypassedExecutions
public int getNumBypassedExecutions()
-
removeCurrentInstance
public static void removeCurrentInstance()
-
getMostRecentInitialTestExecutionReport
public static TestExecutionReport getMostRecentInitialTestExecutionReport()
-
setMostRecentInitialTestExecutionReport
public static void setMostRecentInitialTestExecutionReport(TestExecutionReport report)
-
enableFaultInjection
public void enableFaultInjection()
-
disableFaultInjection
public void disableFaultInjection()
-
writePlaceholderReport
public void writePlaceholderReport()
-
incrementTestScopeCounter
public void incrementTestScopeCounter()
-
incrementTestScopeCounter
public void incrementTestScopeCounter(BlockType blockType)
-
getTestScopeCounter
public int getTestScopeCounter()
-
getLastTestScopeBlockType
public BlockType getLastTestScopeBlockType()
-
beginInvocation
public org.json.JSONObject beginInvocation(org.json.JSONObject payload)
-
endInvocation
public org.json.JSONObject endInvocation(org.json.JSONObject payload, boolean isUpdate)
-
isNewTestExecution
public boolean isNewTestExecution(java.lang.String serviceName)
-
completeIteration
public void completeIteration(int currentIteration)
-
completeIteration
public void completeIteration(int currentIteration, int exceptionOccurred, @Nullable java.lang.Throwable throwable)
-
completeIteration
public void completeIteration(int currentIteration, int exceptionOccurred, java.lang.Throwable throwable, boolean shouldPrintRpcSummary)
-
iterationsRemaining
public int iterationsRemaining()
-
hasNextIteration
public boolean hasNextIteration(int currentIteration)
-
hasNextIteration
public boolean hasNextIteration(int currentIteration, java.lang.String caller)
-
testContainsOrganicFailures
public boolean testContainsOrganicFailures()
-
teardownsCompleted
public void teardownsCompleted(int currentIteration)
-
faultsInjected
@Nullable public java.util.Map<DistributedExecutionIndex,org.json.JSONObject> faultsInjected()
-
executedRpcs
@Nullable public java.util.Map<DistributedExecutionIndex,org.json.JSONObject> executedRpcs()
-
failedRpcs
@Nullable public java.util.Map<DistributedExecutionIndex,org.json.JSONObject> failedRpcs()
-
wasFaultInjected
public boolean wasFaultInjected()
-
wasFaultInjectedOnService
public boolean wasFaultInjectedOnService(java.lang.String serviceName)
-
wasFaultInjectedOnHttpMethod
public boolean wasFaultInjectedOnHttpMethod(com.linecorp.armeria.common.HttpMethod httpMethod, java.lang.String uriPattern)
-
wasFaultInjectedOnMethod
public boolean wasFaultInjectedOnMethod(java.lang.String serviceName, java.lang.String methodName)
-
wasFaultInjectedOnHttpRequest
public boolean wasFaultInjectedOnHttpRequest(com.linecorp.armeria.common.HttpMethod httpMethod, java.lang.String uriPattern, java.lang.String serializedRequestPattern)
-
wasFaultInjectedOnRequest
public boolean wasFaultInjectedOnRequest(java.lang.String serializedRequest)
-
wasFaultInjectedOnMethodWhereRequestContains
public boolean wasFaultInjectedOnMethodWhereRequestContains(java.lang.String serviceName, java.lang.String methodName, java.lang.String contains)
-
terminateFilibuster
public void terminateFilibuster()
-
analysisFile
public void analysisFile(org.json.JSONObject analysisFile)
-
-