Methods
constructQueryExecutor
constructQueryExecutor( $jobId) : \DruidFamiliar\QueryExecutor\DruidNodeDruidQueryExecutor
inherited
constructQueryGenerator
constructQueryGenerator() : \PhpDruidIngest\QueryGenerator\IndexingTaskStatusQueryGenerator
inherited
constructQueryParameters
constructQueryParameters() : \PhpDruidIngest\QueryParameters\IndexingTaskStatusQueryParameters
inherited
constructQueryResponseHandler
constructQueryResponseHandler() : \PhpDruidIngest\ResponseHandler\IndexingTaskStatusResponseHandler
inherited
Wait to retry watching for a pending job.
doWait( $waitDelay)
inherited
getDruidIp
getDruidIp() : mixed
inherited
getDruidPort
getDruidPort() : mixed
inherited
getOnJobCompleted
getOnJobCompleted() : \Closure
getOnJobFailed
getOnJobFailed() : \Closure
getOnJobPending
getOnJobPending() : \Closure
getOutput
getOutput() : \Psr\Log\LoggerInterface
inherited
Response
\Psr\Log\LoggerInterface
getProtocol
getProtocol() : string
inherited
getWatchAttempts
getWatchAttempts() : integer
inherited
handleTaskStatus
handleTaskStatus(\PhpDruidIngest\QueryResponse\IndexingTaskStatusQueryResponse $response) : boolean
inherited
Arguments
Response
boolean
Called when a job's status moves to Completed state.
onJobCompleted() : mixed
inherited
Called when a job's status moves to a Failed state.
onJobFailed() : mixed
inherited
Called when a job's status is still in a Running/Pending state after watching period ends.
onJobPending() : mixed
inherited
Reset watch attempts.
resetWatchAttempts()
inherited
setDruidIp
setDruidIp(mixed $druidIp)
inherited
setDruidPort
setDruidPort(mixed $druidPort)
inherited
setOnJobCompleted
setOnJobCompleted(\Closure $onJobCompleted)
setOnJobFailed
setOnJobFailed(\Closure $onJobFailed)
setOnJobPending
setOnJobPending(\Closure $onJobPending)
setOutput
setOutput(\Psr\Log\LoggerInterface $output)
inherited
Arguments
$output
\Psr\Log\LoggerInterface
setProtocol
setProtocol(string $protocol)
inherited
If a job watching can be cancelled, call this to cancel.
stopWatchingJob() : mixed
inherited
Begin watching given job id.
watchJob(string $jobId) : mixed
inherited
Calls either onJobCompleted or onJobFailed unless stopWatchingJob is called first.
If given job is already completed or failed, the appropriate callback will be called.
Arguments
Response
mixed
Properties
xonJobCompleted
xonJobCompleted : \Closure
xonJobFailed
xonJobFailed : \Closure
xonJobPending
xonJobPending : \Closure
output
output : \Psr\Log\LoggerInterface
inherited
Type(s)
\Psr\Log\LoggerInterface
druidIp
druidIp :
inherited
druidPort
druidPort :
inherited
protocol
protocol :
inherited
druidPath
druidPath :
inherited
druidPathAction
druidPathAction :
inherited
The current number of watch attempts for the currently running job
watchAttempts : integer
inherited
Maximum number of times will attempt to check a status before giving up
maximumWatchAttempts : integer
inherited
Delay between task status polling checks.
watchAttemptDelay : integer
inherited
|
var
|
seconds waited between polling
|
Type(s)
integer
Druid Indexing Task Job Id
watchingJobId : string
inherited