Package com.flowable.platform.service.dashboard.agent

Class AgentCostTokenService

java.lang.Object

com.flowable.platform.service.dashboard.agent.AgentCostTokenService

public class AgentCostTokenService
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AgentCostTokenService.Bucket
static class	AgentCostTokenService.ModelTokens
static class	AgentCostTokenService.Response
static class	AgentCostTokenService.TimeBucketTokens

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	MAX_BUCKETS
protected final tools.jackson.databind.ObjectMapper	objectMapper
protected static final String	QUERY_START_TIME_BOUNDS
protected static final String	QUERY_TOKENS_BY_MODEL_BY_TYPE
protected final QueryService	queryService
protected static final String	TYPE_AGENT_DEFINITIONS
protected static final String	TYPE_END_TIME
protected static final String	TYPE_START_TIME

Constructor Summary

Constructors

Constructor	Description
AgentCostTokenService(QueryService queryService, tools.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
protected void	accumulate(tools.jackson.databind.JsonNode aggs, String aggName, Map<String,AgentCostTokenService.ModelTokens> perModel, com.flowable.platform.service.dashboard.agent.AgentCostTokenService.LongSetter setter)
protected Map<String,tools.jackson.databind.JsonNode>	buildFilterValuesByType(Instant from, Instant to, Collection<String> agentDefinitionKeys)
static List<AgentCostTokenService.Bucket>	computeBuckets(Instant from, Instant to)
AgentCostTokenService.Response	getTokenBreakdown(Instant from, Instant to, List<String> agentDefinitionKeys, String tenantId)
protected Map<String,AgentCostTokenService.ModelTokens>	readBucket(Map<String,tools.jackson.databind.JsonNode> filters, String tenantId)
Instant[]	resolveDataSpan(List<String> agentDefinitionKeys, String tenantId)	Resolves the [earliest, latest] invocation start time for the given agent filter, returned as [from, to] Instants, or null when there is no matching data.
protected tools.jackson.databind.JsonNode	run(String queryKey, String tenantId, Map<String,tools.jackson.databind.JsonNode> filterValuesByType)
protected Map<String,tools.jackson.databind.JsonNode>	translateFilterValues(QueryDefinitionModel model, Map<String,tools.jackson.databind.JsonNode> filterValuesByType)

Methods inherited from class java.lang.Object

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

Field Details

QUERY_TOKENS_BY_MODEL_BY_TYPE

protected static final String QUERY_TOKENS_BY_MODEL_BY_TYPE

See Also:

• Constant Field Values

QUERY_START_TIME_BOUNDS

protected static final String QUERY_START_TIME_BOUNDS

See Also:

• Constant Field Values

TYPE_AGENT_DEFINITIONS

protected static final String TYPE_AGENT_DEFINITIONS

See Also:

• Constant Field Values

TYPE_START_TIME

protected static final String TYPE_START_TIME

See Also:

• Constant Field Values

TYPE_END_TIME

protected static final String TYPE_END_TIME

See Also:

• Constant Field Values

MAX_BUCKETS

protected static final int MAX_BUCKETS

See Also:

• Constant Field Values

queryService

protected final QueryService queryService

objectMapper

protected final tools.jackson.databind.ObjectMapper objectMapper

Constructor Details

AgentCostTokenService

public AgentCostTokenService(QueryService queryService,
 tools.jackson.databind.ObjectMapper objectMapper)

Method Details

getTokenBreakdown

public AgentCostTokenService.Response getTokenBreakdown(Instant from,
 Instant to,
 List<String> agentDefinitionKeys,
 String tenantId)

resolveDataSpan

public Instant[] resolveDataSpan(List<String> agentDefinitionKeys,
 String tenantId)

Resolves the [earliest, latest] invocation start time for the given agent filter, returned as [from, to] Instants, or null when there is no matching data. Used to bucket the full data span when no explicit date range is provided (so a cost-over-time chart shows all data, consistent with the date_histogram-based token charts). The end is nudged by 1ms so the latest invocation falls inside the final bucket.

readBucket

protected Map<String,AgentCostTokenService.ModelTokens> readBucket(Map<String,tools.jackson.databind.JsonNode> filters,
 String tenantId)

accumulate

protected void accumulate(tools.jackson.databind.JsonNode aggs,
 String aggName,
 Map<String,AgentCostTokenService.ModelTokens> perModel,
 com.flowable.platform.service.dashboard.agent.AgentCostTokenService.LongSetter setter)

computeBuckets

public static List<AgentCostTokenService.Bucket> computeBuckets(Instant from,
 Instant to)

run

protected tools.jackson.databind.JsonNode run(String queryKey,
 String tenantId,
 Map<String,tools.jackson.databind.JsonNode> filterValuesByType)

translateFilterValues

protected Map<String,tools.jackson.databind.JsonNode> translateFilterValues(QueryDefinitionModel model,
 Map<String,tools.jackson.databind.JsonNode> filterValuesByType)

buildFilterValuesByType

protected Map<String,tools.jackson.databind.JsonNode> buildFilterValuesByType(Instant from,
 Instant to,
 Collection<String> agentDefinitionKeys)