Modifier and Type | Method and Description |
---|---|
static BidInFlightInfo |
LostAuctionTask.cancelLostAuctionTask(String key,
BidInFlightInfo replacement)
Cancel the task - usually because we won the bid; but sometimes because we got another
explicit notification that we lost, so we don't need the timeout.
|
private void |
BidCandidateManagerSpec_postProcessBid.commonAssertions(boolean result,
boolean expectedResult) |
int |
Orchestrator.getNumberOfPeers() |
int |
AwsOrchestrator.getNumberOfPeers() |
private int |
AwsOrchestrator.getNumberOfPeers(String loadBalancerName) |
static com.lambdaworks.redis.RedisConnection<String,String> |
SegmentEncoderTest.getRedisConnection(RedisServiceConfig config) |
static void |
LogExceptionHandler.init() |
void |
BidCandidateManagerSpec.negativeFlow_declaredButNoRealBids() |
void |
BidCandidateManagerSpec.negativeFlow_minimalConditionsForRun() |
void |
BidCandidateManagerSpec.negativeFlow_setBids_experimentInfoCompleted_UserAttributesFutureException() |
void |
BidCandidateManagerSpec.negativeFlow_setBids_FcDataNotReceived() |
void |
BidCandidateManagerSpec.negativeFlow_setBids_OptOut_someDataNotReceived() |
void |
BidCandidateManagerSpec.negativeFlow_setBids_UserAttributesFutureException() |
void |
BidCandidateManagerSpec.negativeFlow_setBids_UserDataNotReceived() |
void |
BidCandidateManagerSpec.negativeFlow_setBids_UserInfoFutureInterruptedException() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_1candidate_OpenxAdapter() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_1candidate() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_2candidate_LastBidTimeReversed() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_2candidate() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_2candidates() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_AdaptvAdapter_1candidates() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_AdaptvAdapter_bidPriceLongBiggerThenMaxBidPrice_algoMAX() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_AdaptvAdapter_bidPriceLongLessThenMaxBidPrice_algoMAX() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_experimentInfoCompleted() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_FcDataReceived() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_integralCompleted() |
void |
BidCandidateManagerSpec.positiveFlow_setBids_UserDataReceived() |
static void |
LostAuctionTask.scheduleLostAuctionTask(BidInFlightInfo info,
String key,
long winTimeout)
Assume a bid is lost when
winTimeout seconds have
passed. |
private void |
Bidder.startServerNetty() |
void |
LogUtilsSpec.testLogRequest() |
void |
LogUtilsSpec.testLogResponse_notNullSeatbid() |
void |
LogUtilsSpec.testLogResponse() |
void |
LogUtilsSpec.testLogResponseV2() |
Constructor and Description |
---|
Ad_1001001_fake() |
Ad_1001001_fake2() |
Ad_1001001_mock() |
AwsOrchestrator(OrchestratorConfig config) |
Tag_2002002_tagMarker_1001001_fake(Ad ad) |
Constructor and Description |
---|
Ad_1010_integral_fake() |
Ad_1111_fake(boolean test) |
Ad_1234_segments() |
Ad_181818_fake() |
Ad_181818_fake() |
AdImpl() |
AdImpl(boolean testMode) |
BidPriceCalculatorImpl() |
TagImpl(Ad ad) |
Modifier and Type | Method and Description |
---|---|
static Expression<String> |
Helpers.parseStringExpression(String s) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceRunnerSpec_LoadConfig.beforeEach() |
void |
ServiceRunnerSpec_InitOrchestrator.beforeEach() |
void |
ServiceRunnerSpec_InitExecutors.beforeEach() |
void |
ServiceRunnerSpec_initProviders.negativeFlow_interruptsExecutionIfGetProvidersReturnsNull() |
void |
ServiceRunnerSpec_initAdapters.negativeFlow_throwsExceptionIfCouldNotInitializeAllAdapters() |
void |
ServiceRunnerSpec_LoadConfig.negativeFlowWhenConfigFileNameIsNull() |
void |
ServiceRunnerSpec_ParseCommandLineArgs.noArgumentsNegativeFlow() |
void |
ServiceRunnerSpec_ParseCommandLineArgs.noOptionsNegativeFlow() |
void |
ServiceRunnerSpec_initAdapters.positiveFlow_expectedLogsIfAllAdaptersAreInitialized() |
void |
ServiceRunnerSpec_initCaches.positiveFlow_initializesCachesIfConfigsAreNull() |
void |
ServiceRunnerSpec_initCodecs.positiveFlow_initializesNoopCodecIfCodecClassIsUnsuitable() |
void |
ServiceRunnerSpec_initCodecs.positiveFlow_initializesRequestedCodecIfCodecClassIsSuitable() |
void |
ServiceRunnerSpec_InitOrchestrator.positiveFlow_LocalOchestrator() |
void |
ServiceRunnerSpec_ParseCommandLineArgs.positiveFlow() |
void |
ServiceRunnerSpec_LoadConfig.positiveFlowWhenConfigFileNameIsNull() |
void |
ServiceRunnerSpec_LoadConfig.positiveFlowWhenConfigFileNameNotNull() |
Modifier and Type | Method and Description |
---|---|
void |
AdCacheSpec_reserveMoney.CalcControlValues.calculate(String adId) |
void |
UserCacheDaoImplSpec_ALL.constructor_setsFieldValues() |
private AdCache |
AdCacheSpec_reserveMoney.createAdCache() |
AdCache |
AdCacheSpec_Refresh.createAdCache() |
private RedisDaoCounters |
AdCacheSpec_reserveMoney.createRedisDaoCountersMock(Ad ad,
long wins,
long bids,
long spendAmount,
long bidAmount) |
private RedisDaoCounters |
AdCacheSpec_Refresh.createRedisDaoCountersMock(List<AdCacheSpec_Refresh.AdData> ads) |
private int |
AdCache.getNumberOfPeers(com.lambdaworks.redis.RedisConnection<String,String> redisCon) |
private com.lambdaworks.redis.RedisConnection<String,String> |
AdCache.getRedisConnection() |
private com.lambdaworks.redis.RedisConnection<String,String> |
AdCacheITTest.getRedisConnection(AdCacheConfig config) |
void |
UserCacheDaoImplSpec_ALL.getUserInfo_returnsExpectedValue() |
void |
AdCache.init() |
List<Ad> |
AdCache.loadAdsFromDir(String adsDir,
String subDir,
Boolean useSanboxClassloader,
StringBuilder msg,
com.lambdaworks.redis.RedisConnection<String,String> redisCon) |
private BidPriceCalculator |
AdCache.loadBidPriceCalculator(File groovyPkgDir,
groovy.lang.GroovyClassLoader loader,
File f) |
void |
AdCacheSpec_Refresh.negativeFlow_adFileNameIsEmpty() |
void |
AdCacheSpec_Refresh.negativeFlow_adFileNameNeedsNumber() |
void |
AdCacheSpec_Refresh.negativeFlow_noAdsInAdDir() |
void |
AdCacheSpec_Refresh.negativeFlow_noBidPriceCalculatorsInDir() |
void |
AdCacheSpec_reserveMoney.negativeFlow_noMoneyLeft() |
void |
AdCacheSpec_reserveMoney.negativeFlow_notABidder() |
void |
AdCacheSpec_Refresh.negativeFlow_redisConnectionIsNull() |
void |
AdCacheSpec_constructor.negativeFlow_throwsExceptionIfMessageTtlMinutesIsNotPositive() |
void |
AdCacheSpec_setBudget.negativeFlow_throwsExceptionIfRedisConnectionIsNull() |
void |
AdCacheSpec_init.positiveFlow_initializesNecessaryFieldsAndSchedulesTask() |
void |
AdCacheSpec_constructor.positiveFlow_initializesNecessaryFieldsIfAllConfigSataAreCorrect() |
void |
AdCacheSpec_setBudget.positiveFlow_returnsExpectedResult() |
private AdCache.BudgetAllocationResult |
AdCache.reserveMoney(com.lambdaworks.redis.RedisConnection<String,String> redisCon,
Ad ad)
Reserve money from the main budget cache for a given ad.
|
String |
AdCache.setBudget(String adId,
long amount)
Only for use in Admin tools.
|
String |
AdCacheSpec_Refresh.testRefresh(AdCache adCache,
AdCacheSpec_Refresh.AdData ad) |
private String |
AdCacheSpec_Refresh.testRefresh(AdCache adCache,
List<AdCacheSpec_Refresh.AdData> ads) |
private String |
AdCacheSpec_Refresh.testRefresh(AdCacheSpec_Refresh.AdData ad) |
private String |
AdCacheSpec_Refresh.testRefresh(List<AdCacheSpec_Refresh.AdData> ads) |
private void |
AdCacheSpec_reserveMoney.testReserveMoney_prevAdIsNotNull(boolean positeveFlow,
AdCacheSpec_reserveMoney.ControlValues cv) |
private void |
AdCache.tmpPopulateAdIdToBpcId()
Deprecated.
|
Constructor and Description |
---|
AdCache(AdCacheConfig config) |
CalcControlValues(String adId) |
Modifier and Type | Method and Description |
---|---|
DbConfig |
DbConfigs.findDbConfig(String name) |
Modifier and Type | Method and Description |
---|---|
long |
DaoCounters.addAndGet(String key,
long val) |
T |
DaoMap.get(String key) |
long |
DaoCounters.get(String key) |
long |
DaoCounters.getAndSet(String key,
long val) |
Future<T> |
DaoMap.getAsync(String key) |
void |
DbService.init(DbConfig config) |
void |
DaoMap.putAsync(String key,
T value) |
void |
DaoMap.putAsync(String key,
T value,
Long milliseconds) |
T |
DaoMap.remove(String key) |
T |
DaoMap.replace(String key,
T value)
Atomic guarantee
|
void |
DaoCounters.set(String key,
long val) |
Modifier and Type | Method and Description |
---|---|
void |
AerospikeDBService.init(DbConfig config) |
void |
AerospikeDaoMapOfUserAttributesSpec.updateImpressionsHistoryAsync() |
Modifier and Type | Method and Description |
---|---|
void |
CollectionsDbService.init(DbConfig config) |
void |
CollectionsDaoMap.putAsync(String key,
T value,
Long milliseconds) |
Modifier and Type | Method and Description |
---|---|
void |
DynamoDBService.init(DbConfig c) |
void |
DynamoDBServiceSpec_init.testNoENV_DYNAMO_ENDPOINT() |
void |
DynamoDBServiceSpec_init.testWrongDBConfig() |
Modifier and Type | Method and Description |
---|---|
void |
HazelcastService.init(DbConfig config) |
void |
HazelcastService.makeHazelConfig(Orchestrator orch) |
void |
HazelcastServiceSpec.negativeFlow_constructor_AwsOrchestrator_ENV_EC2_ENDPOINTShouldBeSet() |
void |
HazelcastServiceSpec.negativeFlow_constructor_AwsOrchestrator_ENV_ELB_ENDPOINTShouldBeSet() |
void |
HazelcastServiceSpec.positiveFlow_constructor_sholudSetIdGenerator() |
void |
HazelcastServiceSpec.positiveFlow_constructorNoInit_sholudNotSetIdGenerator2() |
void |
HzDaoShortLivedMap.putAsync(String key,
T value,
Long milliseconds) |
Constructor and Description |
---|
HazelcastService(ServiceRunner runner,
HazelcastServiceConfig config) |
HazelcastService(ServiceRunner runner,
HazelcastServiceConfig config,
boolean noInit) |
Modifier and Type | Method and Description |
---|---|
long |
RedisDaoCounters.addAndGet(String key,
long val) |
String |
RedisStringDaoShortLivedMap.get(String key) |
long |
RedisDaoCounters.get(String key) |
CacheableWebResponse |
RedisCacheableWebResponseDaoShortLivedMap.get(String key) |
long |
RedisDaoCounters.getAndSet(String key,
long val) |
Future<CacheableWebResponse> |
RedisCacheableWebResponseDaoShortLivedMap.getAsync(String key) |
T |
RedisDaoImpl.getSafe(Future<T> f) |
static <T> T |
RedisJsonFuture.getSafe(Future<T> f,
RedisService svc) |
void |
RedisService.init(DbConfig config) |
void |
RedisServiceSpec.negativeFlow_getConnection() |
void |
RedisServiceSpec.negativeFlow_init_shouldNotSetWrongServiceConfig() |
void |
RedisServiceSpec.negativeFlow_refreshPool_canNotConnect() |
void |
RedisServiceSpec.negativeFlow_run_canNotConnect() |
void |
RedisServiceSpec.positiveFlow_close() |
void |
RedisCacheableWebResponseDaoShortLivedMapSpec_PLAIN.positiveFlow_getAsync() |
void |
RedisServiceSpec.positiveFlow_getConnection() |
void |
RedisServiceSpec.positiveFlow_getDaoShortLivedMap() |
void |
RedisServiceSpec.positiveFlow_init_shouldCallrefreshPool() |
void |
RedisServiceSpec.positiveFlow_init_shouldSetOtherParams() |
void |
RedisServiceSpec.positiveFlow_init_shouldSetRedisServiceConfig() |
void |
RedisStringDaoShortLivedMapSpec_ALL.positiveFlow_replace() |
void |
RedisServiceSpec.positiveFlow_run() |
void |
RedisBidInfoDaoShortLivedMap.putAsync(String key,
BidInFlightInfo value,
Long milliseconds) |
void |
RedisCacheableWebResponseDaoShortLivedMap.putAsync(String key,
CacheableWebResponse value,
Long milliseconds) |
String |
RedisStringDaoShortLivedMap.remove(String key) |
BidInFlightInfo |
RedisBidInfoDaoShortLivedMap.remove(String key) |
CacheableWebResponse |
RedisCacheableWebResponseDaoShortLivedMap.replace(String key,
CacheableWebResponse value) |
String |
RedisStringDaoShortLivedMap.replace(String key,
String value) |
Modifier and Type | Method and Description |
---|---|
Object |
OpsSvc.debugNurl(String nurlId) |
static BidInFlightInfo |
StatsSvc.handleWinLossError(String url,
ExchangeAdapter adapter,
String bId,
String brId,
String adId,
String reason,
Long winPrice) |
void |
OpsSvcSpec_debugNurl.negativeFlow_throwExceptionIfCacheableWebResponseWasNotFound() |
void |
OpsSvcSpec_debugNurl.positiveFlow_returnResponseIfCacheableWebResponseWasFound() |
void |
AdminSvc.setBudget(javax.ws.rs.container.AsyncResponse response,
String adId,
long amount,
String auth) |
Modifier and Type | Method and Description |
---|---|
static com.lambdaworks.redis.RedisConnection<String,String> |
AdaptersBaseTest.getRedisConnection(RedisServiceConfig config) |
Constructor and Description |
---|
AdXAdapter() |
AdXAdapter(boolean test)
The only one purpose of this constructors is to run test AdxTest
|
Constructor and Description |
---|
OpenXAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
PubmaticAdapterSpec.constructorPositiveFlow_shouldSetPubmaticConfig() |
Constructor and Description |
---|
PubmaticAdapter() |
PubmaticBidObject(Map map) |
PubmaticWinLossObject(Object o) |
Modifier and Type | Method and Description |
---|---|
static Provider |
ProviderFactory.getProvider(ServiceRunner runner,
String name,
Map config) |
void |
Provider.init() |
void |
Provider.initAsync(SimpleCallback callback) |
ProviderInfoRequired |
Provider.parse(String json) |
Modifier and Type | Method and Description |
---|---|
void |
IpBlackListProvider.init() |
void |
IpBlackListProvider.initAsync(SimpleCallback callback) |
private void |
IpBlackListProvider.initInternal(SimpleCallback simpleCallback) |
ProviderInfoRequired |
IpBlackListProvider.parse(String json) |
Modifier and Type | Method and Description |
---|---|
void |
SkyhookProvider.init() |
void |
SkyhookProvider.initAsync(SimpleCallback callback) |
ProviderInfoRequired |
SkyhookProvider.parse(String json) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceRunner.initAdapters() |
void |
ServiceRunner.initCaches() |
void |
ServiceRunner.initCodecs() |
void |
ServiceRunner.initDbServices()
|
void |
ServiceRunner.initLogging() |
void |
ServiceRunner.initOrchestrator() |
void |
ServiceRunner.initProviders() |
Lot49Config |
ServiceRunner.loadConfig() |
static Config |
Utils.loadConfig(String fileName,
Class<? extends Config> configClass) |
void |
ServiceRunner.parseCommandLineArgs(String[] argv) |
static String |
Utils.readFile(File f) |
static String |
Utils.readFile(String s) |