Package com.devcycle.sdk.server.local.bucketing

Class LocalBucketing

java.lang.Object

com.devcycle.sdk.server.local.bucketing.LocalBucketing

public class LocalBucketing
extends Object

Constructor Summary

Constructors

Constructor	Description
LocalBucketing()

Method Summary

Modifier and Type	Method	Description
FlushPayload[]	flushEventQueue(String sdkKey)
BucketedUserConfig	generateBucketedConfig(String sdkKey, DevCycleUser user)
String	getConfigMetadata(String sdkKey)
int	getEventQueueSize(String sdkKey)
byte[]	getVariableForUserProtobuf(byte[] serializedParams)
void	initEventQueue(String sdkKey, String clientUUID, String options)
void	onPayloadFailure(String sdkKey, String payloadId, boolean retryable)
void	onPayloadSuccess(String sdkKey, String payloadId)
void	queueAggregateEvent(String sdkKey, String event, String variableVariationMap)
void	queueEvent(String sdkKey, String user, String event)
void	setClientCustomData(String sdkKey, String customData)
void	setPlatformData(String platformData)
void	storeConfig(String sdkKey, String config)

Methods inherited from class java.lang.Object

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

Constructor Details

LocalBucketing

public LocalBucketing()

Method Details

storeConfig

public void storeConfig(String sdkKey,
 String config)

setPlatformData

public void setPlatformData(String platformData)

setClientCustomData

public void setClientCustomData(String sdkKey,
 String customData)

generateBucketedConfig

public BucketedUserConfig generateBucketedConfig(String sdkKey,
 DevCycleUser user)
                                          throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

getVariableForUserProtobuf

public byte[] getVariableForUserProtobuf(byte[] serializedParams)

initEventQueue

public void initEventQueue(String sdkKey,
 String clientUUID,
 String options)

queueEvent

public void queueEvent(String sdkKey,
 String user,
 String event)

queueAggregateEvent

public void queueAggregateEvent(String sdkKey,
 String event,
 String variableVariationMap)

flushEventQueue

public FlushPayload[] flushEventQueue(String sdkKey)
                               throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

onPayloadFailure

public void onPayloadFailure(String sdkKey,
 String payloadId,
 boolean retryable)

onPayloadSuccess

public void onPayloadSuccess(String sdkKey,
 String payloadId)

getEventQueueSize

public int getEventQueueSize(String sdkKey)

getConfigMetadata

public String getConfigMetadata(String sdkKey)