Index

A C D E G H I K L M N O P R S T W
All Classes and Interfaces|All Packages

A

agentmain(String, Instrumentation) - Static method in class ai.superstream.agent.SuperstreamAgent

AgentMain method, called when the agent is loaded after JVM startup.

ai.superstream.agent - package ai.superstream.agent

ai.superstream.core - package ai.superstream.core

ai.superstream.model - package ai.superstream.model

ai.superstream.util - package ai.superstream.util

applyOptimalConfiguration(Properties, Map<String, Object>) - Method in class ai.superstream.core.ConfigurationOptimizer

Apply the optimal configuration to the producer properties.

C

calculateImpactScore() - Method in class ai.superstream.model.TopicConfiguration

Calculate the potential impact of optimization for this topic.

ClientMessage - Class in ai.superstream.model

Represents a message to be sent to the superstream.clients topic.

ClientMessage() - Constructor for class ai.superstream.model.ClientMessage

ClientMessage(int, boolean, String, String, String, String, String, Map<String, Object>, Map<String, Object>) - Constructor for class ai.superstream.model.ClientMessage

ClientReporter - Class in ai.superstream.core

Reports client information to the superstream.clients topic.

ClientReporter() - Constructor for class ai.superstream.core.ClientReporter

ConfigurationOptimizer - Class in ai.superstream.core

Optimizes Kafka producer configurations based on metadata.

ConfigurationOptimizer() - Constructor for class ai.superstream.core.ConfigurationOptimizer

convertPropertiesToMap(Properties) - Static method in class ai.superstream.core.SuperstreamManager

D

debug(String) - Method in class ai.superstream.util.SuperstreamLogger

Log a debug message with the superstream prefix.

debug(String, Object...) - Method in class ai.superstream.util.SuperstreamLogger

Log a debug message with parameters and the superstream prefix.

E

equals(Object) - Method in class ai.superstream.model.ClientMessage

equals(Object) - Method in class ai.superstream.model.MetadataMessage

equals(Object) - Method in class ai.superstream.model.TopicConfiguration

error(String) - Method in class ai.superstream.util.SuperstreamLogger

Log an error message with the superstream prefix.

error(String, Object...) - Method in class ai.superstream.util.SuperstreamLogger

Log an error message with parameters and the superstream prefix.

error(String, Throwable) - Method in class ai.superstream.util.SuperstreamLogger

Log an error message with an exception and the superstream prefix.

extractProperties(Object[]) - Static method in class ai.superstream.agent.KafkaProducerInterceptor

Extract Properties object from constructor arguments.

G

getClientId() - Method in class ai.superstream.model.ClientMessage

getClientType() - Method in class ai.superstream.model.ClientMessage

getClientVersion() - Method in class ai.superstream.model.ClientMessage

getDailyWritesBytes() - Method in class ai.superstream.model.TopicConfiguration

getInstance() - Static method in class ai.superstream.core.SuperstreamManager

Get the singleton instance of the SuperstreamManager.

getIpAddress() - Method in class ai.superstream.model.ClientMessage

getLanguage() - Method in class ai.superstream.model.ClientMessage

getLocalIpAddress() - Static method in class ai.superstream.util.NetworkUtils

Get the local IP address.

getLogger(Class<?>) - Static method in class ai.superstream.util.SuperstreamLogger

Get a logger for the specified class.

getMetadataMessage(String, Properties) - Method in class ai.superstream.core.MetadataConsumer

Get the metadata message from the Kafka cluster.

getOptimalConfiguration(MetadataMessage, List<String>) - Method in class ai.superstream.core.ConfigurationOptimizer

Get the optimal configuration for a set of topics.

getOptimizedConfiguration() - Method in class ai.superstream.model.ClientMessage

getOptimizedConfiguration() - Method in class ai.superstream.model.TopicConfiguration

getOriginalConfiguration() - Method in class ai.superstream.model.ClientMessage

getPotentialReductionPercentage() - Method in class ai.superstream.model.TopicConfiguration

getSuperstreamClusterId() - Method in class ai.superstream.model.ClientMessage

getSuperstreamClusterId() - Method in class ai.superstream.model.MetadataMessage

getTopicName() - Method in class ai.superstream.model.TopicConfiguration

getTopicsConfiguration() - Method in class ai.superstream.model.MetadataMessage

H

hashCode() - Method in class ai.superstream.model.ClientMessage

hashCode() - Method in class ai.superstream.model.MetadataMessage

hashCode() - Method in class ai.superstream.model.TopicConfiguration

I

info(String) - Method in class ai.superstream.util.SuperstreamLogger

Log an info message with the superstream prefix.

info(String, Object...) - Method in class ai.superstream.util.SuperstreamLogger

Log an info message with parameters and the superstream prefix.

isActive() - Method in class ai.superstream.model.ClientMessage

isActive() - Method in class ai.superstream.model.MetadataMessage

isInitialProducerCreation() - Static method in class ai.superstream.agent.KafkaProducerInterceptor

Determines if this constructor call is the initial creation from application code rather than an internal delegation between constructors.

isOptimizationInProgress() - Static method in class ai.superstream.core.SuperstreamManager

Check if optimization is already in progress for the current thread.

K

KafkaProducerInterceptor - Class in ai.superstream.agent

Intercepts KafkaProducer constructor calls to optimize configurations.

KafkaProducerInterceptor() - Constructor for class ai.superstream.agent.KafkaProducerInterceptor

L

logger - Static variable in class ai.superstream.agent.KafkaProducerInterceptor

M

MetadataConsumer - Class in ai.superstream.core

Consumes messages from the superstream.metadata_v1 topic.

MetadataConsumer() - Constructor for class ai.superstream.core.MetadataConsumer

MetadataMessage - Class in ai.superstream.model

Represents a message from the superstream.metadata_v1 topic.

MetadataMessage() - Constructor for class ai.superstream.model.MetadataMessage

MetadataMessage(int, boolean, List<TopicConfiguration>) - Constructor for class ai.superstream.model.MetadataMessage

N

NetworkUtils - Class in ai.superstream.util

Utility class for network-related operations.

NetworkUtils() - Constructor for class ai.superstream.util.NetworkUtils

O

onEnter(Object[]) - Static method in class ai.superstream.agent.KafkaProducerInterceptor

Called before the KafkaProducer constructor.

optimizeProducer(String, String, Properties) - Method in class ai.superstream.core.SuperstreamManager

Optimize the producer properties for a given Kafka cluster.

P

premain(String, Instrumentation) - Static method in class ai.superstream.agent.SuperstreamAgent

Premain method, called when the agent is loaded during JVM startup.

R

reportClient(String, Properties, int, boolean, String, Map<String, Object>, Map<String, Object>) - Method in class ai.superstream.core.ClientReporter

Report client information to the superstream.clients topic.

S

setActive(boolean) - Method in class ai.superstream.model.ClientMessage

setActive(boolean) - Method in class ai.superstream.model.MetadataMessage

setClientId(String) - Method in class ai.superstream.model.ClientMessage

setClientType(String) - Method in class ai.superstream.model.ClientMessage

setClientVersion(String) - Method in class ai.superstream.model.ClientMessage

setDailyWritesBytes(long) - Method in class ai.superstream.model.TopicConfiguration

setIpAddress(String) - Method in class ai.superstream.model.ClientMessage

setLanguage(String) - Method in class ai.superstream.model.ClientMessage

setOptimizationInProgress(boolean) - Static method in class ai.superstream.core.SuperstreamManager

Set the optimization in progress flag for the current thread.

setOptimizedConfiguration(Map<String, Object>) - Method in class ai.superstream.model.ClientMessage

setOptimizedConfiguration(Map<String, Object>) - Method in class ai.superstream.model.TopicConfiguration

setOriginalConfiguration(Map<String, Object>) - Method in class ai.superstream.model.ClientMessage

setPotentialReductionPercentage(int) - Method in class ai.superstream.model.TopicConfiguration

setSuperstreamClusterId(int) - Method in class ai.superstream.model.ClientMessage

setSuperstreamClusterId(int) - Method in class ai.superstream.model.MetadataMessage

setTopicName(String) - Method in class ai.superstream.model.TopicConfiguration

setTopicsConfiguration(List<TopicConfiguration>) - Method in class ai.superstream.model.MetadataMessage

SuperstreamAgent - Class in ai.superstream.agent

Java agent entry point for the Superstream library.

SuperstreamAgent() - Constructor for class ai.superstream.agent.SuperstreamAgent

SuperstreamLogger - Class in ai.superstream.util

Custom logger for the Superstream library.

SuperstreamManager - Class in ai.superstream.core

Main manager class for the Superstream library.

T

TopicConfiguration - Class in ai.superstream.model

Represents the configuration for a specific Kafka topic.

TopicConfiguration() - Constructor for class ai.superstream.model.TopicConfiguration

TopicConfiguration(String, int, long, Map<String, Object>) - Constructor for class ai.superstream.model.TopicConfiguration

toString() - Method in class ai.superstream.model.ClientMessage

toString() - Method in class ai.superstream.model.MetadataMessage

toString() - Method in class ai.superstream.model.TopicConfiguration

W

warn(String) - Method in class ai.superstream.util.SuperstreamLogger

Log a warning message with the superstream prefix.

warn(String, Object...) - Method in class ai.superstream.util.SuperstreamLogger

Log a warning message with parameters and the superstream prefix.

A C D E G H I K L M N O P R S T W
All Classes and Interfaces|All Packages