com.newrelic.agent.transport.serverless

Class DataSenderServerlessImpl

java.lang.Object

com.newrelic.agent.transport.serverless.DataSenderServerlessImpl

All Implemented Interfaces:

DataSender

public class DataSenderServerlessImpl
extends java.lang.Object
implements DataSender

Constructor Summary

Constructors

Constructor and Description
DataSenderServerlessImpl(DataSenderServerlessConfig config, IAgentLogger logger, ServerlessService serverlessService, ServerlessWriter serverlessWriter)

Method Summary

Modifier and Type	Method and Description
void	commitAndFlush() Saves any buffered telemetry to stdout/file and flushes out the buffer.
static java.lang.String	compressAndEncode(java.lang.String source) gzip compress and base64 encode.
java.util.Map<java.lang.String,java.lang.Object>	connect(java.util.Map<java.lang.String,java.lang.Object> startupOptions)
java.util.List<java.util.List<?>>	getAgentCommands()
<T extends com.newrelic.agent.model.AnalyticsEvent & org.json.simple.JSONStreamAware> void	sendAnalyticsEvents(int reservoirSize, int eventsSeen, java.util.Collection<T> events) Send non-aggregated events for analytics
void	sendCommandResults(java.util.Map<java.lang.Long,java.lang.Object> commandResults)
void	sendCustomAnalyticsEvents(int reservoirSize, int eventsSeen, java.util.Collection<? extends com.newrelic.agent.model.CustomInsightsEvent> events) Send non-aggregated custom events for analytics
void	sendErrorData(java.util.List<TracedError> errors)
void	sendErrorEvents(int reservoirSize, int eventsSeen, java.util.Collection<com.newrelic.agent.model.ErrorEvent> errorEvents)
void	sendLogEvents(java.util.Collection<? extends com.newrelic.agent.model.LogEvent> events) Send non-aggregated Log events
void	sendMetricData(long beginTimeMillis, long endTimeMillis, java.util.List<MetricData> metricData) Send metric data to New Relic.
void	sendModules(java.util.List<? extends org.json.simple.JSONStreamAware> jarDataToSend)
java.util.List<java.lang.Long>	sendProfileData(java.util.List<ProfileData> profiles) Send thread profiles to New Relic.
void	sendSpanEvents(int reservoirSize, int eventsSeen, java.util.Collection<com.newrelic.agent.model.SpanEvent> events) Send non-aggregated span events
void	sendSqlTraceData(java.util.List<SqlTrace> sqlTraces)
void	sendTransactionTraceData(java.util.List<TransactionTrace> traces)
void	shutdown(long timeMillis)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataSenderServerlessImpl

public DataSenderServerlessImpl(DataSenderServerlessConfig config,
                                IAgentLogger logger,
                                ServerlessService serverlessService,
                                ServerlessWriter serverlessWriter)

Method Detail

connect

public java.util.Map<java.lang.String,java.lang.Object> connect(java.util.Map<java.lang.String,java.lang.Object> startupOptions)
                                                         throws java.lang.Exception

Specified by:

connect in interface DataSender

Throws:

java.lang.Exception

getAgentCommands

public java.util.List<java.util.List<?>> getAgentCommands()
                                                   throws java.lang.Exception

Specified by:

getAgentCommands in interface DataSender

Throws:

java.lang.Exception

sendCommandResults

public void sendCommandResults(java.util.Map<java.lang.Long,java.lang.Object> commandResults)
                        throws java.lang.Exception

Specified by:

sendCommandResults in interface DataSender

Throws:

java.lang.Exception

sendErrorData

public void sendErrorData(java.util.List<TracedError> errors)
                   throws java.lang.Exception

Specified by:

sendErrorData in interface DataSender

Throws:

java.lang.Exception

sendErrorEvents

public void sendErrorEvents(int reservoirSize,
                            int eventsSeen,
                            java.util.Collection<com.newrelic.agent.model.ErrorEvent> errorEvents)
                     throws java.lang.Exception

Specified by:

sendErrorEvents in interface DataSender

Throws:

java.lang.Exception

sendAnalyticsEvents

public <T extends com.newrelic.agent.model.AnalyticsEvent & org.json.simple.JSONStreamAware> void sendAnalyticsEvents(int reservoirSize,
                                                                                                                      int eventsSeen,
                                                                                                                      java.util.Collection<T> events)
                                                                                                               throws java.lang.Exception

Description copied from interface: DataSender

Send non-aggregated events for analytics

Specified by:

sendAnalyticsEvents in interface DataSender

Throws:

java.lang.Exception

sendCustomAnalyticsEvents

public void sendCustomAnalyticsEvents(int reservoirSize,
                                      int eventsSeen,
                                      java.util.Collection<? extends com.newrelic.agent.model.CustomInsightsEvent> events)
                               throws java.lang.Exception

Description copied from interface: DataSender

Send non-aggregated custom events for analytics

Specified by:

sendCustomAnalyticsEvents in interface DataSender

Throws:

java.lang.Exception

sendLogEvents

public void sendLogEvents(java.util.Collection<? extends com.newrelic.agent.model.LogEvent> events)
                   throws java.lang.Exception

Description copied from interface: DataSender

Send non-aggregated Log events

Specified by:

sendLogEvents in interface DataSender

Throws:

java.lang.Exception

sendSpanEvents

public void sendSpanEvents(int reservoirSize,
                           int eventsSeen,
                           java.util.Collection<com.newrelic.agent.model.SpanEvent> events)
                    throws java.lang.Exception

Description copied from interface: DataSender

Send non-aggregated span events

Specified by:

sendSpanEvents in interface DataSender

Throws:

java.lang.Exception

sendMetricData

public void sendMetricData(long beginTimeMillis,
                           long endTimeMillis,
                           java.util.List<MetricData> metricData)
                    throws java.lang.Exception

Description copied from interface: DataSender

Send metric data to New Relic.

Specified by:

sendMetricData in interface DataSender

Parameters:

beginTimeMillis - the last time metric data was sent to New Relic

endTimeMillis - the time now

metricData - the metric data to send

Throws:

java.lang.Exception - if there is a problem sending the metric data

sendProfileData

public java.util.List<java.lang.Long> sendProfileData(java.util.List<ProfileData> profiles)
                                               throws java.lang.Exception

Description copied from interface: DataSender

Send thread profiles to New Relic.

Specified by:

sendProfileData in interface DataSender

Parameters:

profiles - the profiles to send

Returns:

a list of profile IDs for the profiles

Throws:

java.lang.Exception - if there is a problem sending the profiles

sendSqlTraceData

public void sendSqlTraceData(java.util.List<SqlTrace> sqlTraces)
                      throws java.lang.Exception

Specified by:

sendSqlTraceData in interface DataSender

Throws:

java.lang.Exception

sendTransactionTraceData

public void sendTransactionTraceData(java.util.List<TransactionTrace> traces)
                              throws java.lang.Exception

Specified by:

sendTransactionTraceData in interface DataSender

Throws:

java.lang.Exception

sendModules

public void sendModules(java.util.List<? extends org.json.simple.JSONStreamAware> jarDataToSend)
                 throws java.lang.Exception

Specified by:

sendModules in interface DataSender

Throws:

java.lang.Exception

shutdown

public void shutdown(long timeMillis)
              throws java.lang.Exception

Specified by:

shutdown in interface DataSender

Throws:

java.lang.Exception

commitAndFlush

public void commitAndFlush()
                    throws java.io.IOException

Description copied from interface: DataSender

Saves any buffered telemetry to stdout/file and flushes out the buffer. Used for finishing serverless harvests and is a No-Op in all other scenarios.

Specified by:

commitAndFlush in interface DataSender

Throws:

java.io.IOException

compressAndEncode

public static java.lang.String compressAndEncode(java.lang.String source)

gzip compress and base64 encode.

Parameters:

source - String to be compressed and encoded

Returns:

String compressed and encoded