Package org.aksw.iguana.cc.worker

Class HttpWorker

java.lang.Object

org.aksw.iguana.cc.worker.HttpWorker

Direct Known Subclasses:

SPARQLProtocolWorker

public abstract class HttpWorker
extends Object

Interface for the Worker Thread used in the Stresstest

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	HttpWorker.CompletionTarget
static interface	HttpWorker.Config
static final record	HttpWorker.ExecutionStats
static final record	HttpWorker.QueryMixes
static final record	HttpWorker.Result
static final record	HttpWorker.TimeLimit

Field Summary

Fields

Modifier and Type	Field	Description
protected final HttpWorker.Config	config
protected final QuerySelector	querySelector
protected final ResponseBodyProcessor	responseBodyProcessor
protected final long	workerID

Constructor Summary

Constructors

Constructor	Description
HttpWorker(long workerID, ResponseBodyProcessor responseBodyProcessor, HttpWorker.Config config)

Method Summary

Modifier and Type	Method	Description
static String	basicAuth(String username, String password)
HttpWorker.Config	config()
long	getWorkerID()
abstract CompletableFuture<HttpWorker.Result>	start()

Methods inherited from class java.lang.Object

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

Field Details

workerID

protected final long workerID

config

protected final HttpWorker.Config config

responseBodyProcessor

protected final ResponseBodyProcessor responseBodyProcessor

querySelector

protected final QuerySelector querySelector

Constructor Details

HttpWorker

public HttpWorker(long workerID,
 ResponseBodyProcessor responseBodyProcessor,
 HttpWorker.Config config)

Method Details

basicAuth

public static String basicAuth(String username,
 String password)

start

public abstract CompletableFuture<HttpWorker.Result> start()

config

public HttpWorker.Config config()

getWorkerID

public long getWorkerID()