com.yahoo.bullet.rest.service

Class StatusService

java.lang.Object

com.yahoo.bullet.rest.service.StatusService

All Implemented Interfaces:

Runnable

@Service
public class StatusService
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor and Description
StatusService(QueryService queryService, HandlerService handlerService, long period, long retries, Boolean enabled, int maxConcurrentQueries) Creates an instance with a tick period and number of retries.

Method Summary

Modifier and Type	Method and Description
boolean	queryLimitReached() This checks if the configured max concurrent queries limit has been exceeded.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

StatusService

@Autowired
public StatusService(QueryService queryService,
                                HandlerService handlerService,
                                @Value(value="${bullet.status.tick-ms}")
                                long period,
                                @Value(value="${bullet.status.retries}")
                                long retries,
                                @Value(value="${bullet.status.enabled}")
                                Boolean enabled,
                                @Value(value="${bullet.query.synchronous.max.concurrency}")
                                int maxConcurrentQueries)

Creates an instance with a tick period and number of retries.

Parameters:

queryService - The QueryService to use.

handlerService - The HandlerService to use.

period - Rate at which to ping backend in ms.

retries - Number of times ping can fail before backend status is considered not ok.

enabled - Whether this backend status service is enabled or not.

maxConcurrentQueries - Number of maximum simultaneous synchronous queries that can be run.

Method Detail

run

public void run()

Specified by:

run in interface Runnable

queryLimitReached

public boolean queryLimitReached()

This checks if the configured max concurrent queries limit has been exceeded.

Returns:

A boolean indicating whether or not the query limit has been reached.