Package io.vertigo.core.plugins.analytics.log

Class SocketLoggerAnalyticsConnectorPlugin

java.lang.Object

io.vertigo.core.plugins.analytics.log.SocketLoggerAnalyticsConnectorPlugin

All Implemented Interfaces:

AnalyticsConnectorPlugin, Activeable, CoreComponent, Plugin

public final class SocketLoggerAnalyticsConnectorPlugin
extends Object
implements AnalyticsConnectorPlugin, Activeable

Processes connector which use the log4j SocketAppender.

Author:

mlaroche, pchretien, npiedeloup

Constructor Summary

Constructors

Constructor

Description

SocketLoggerAnalyticsConnectorPlugin(ParamManager paramManager, Optional<String> hostNameOpt, Optional<Integer> portOpt, Optional<String> hostNameParamOpt, Optional<String> portParamOpt, Optional<String> nodeNameParamOpt, Optional<String> envNameParamOpt, Optional<Integer> bufferSizeOpt, Optional<Integer> batchSizeOpt, Optional<Boolean> jsonLayoutOpt, Optional<String> jsonLayoutParamOpt, Optional<Boolean> compressOutputStreamOpt, Optional<String> compressOutputStreamParamOpt)

Constructor.

Method Summary

Modifier and Type	Method	Description
void	add(HealthCheck healthCheck)	Adds a healthCheck to a connector which acts as a consumer.
void	add(Metric metric)	Adds a metric to a connector which acts as a consumer.
void	add(TraceSpan span)	Adds a span to a connector which acts as a consumer.
void	pollQueue()	Daemon to unstack processes to end them
void	start()	Initializes and activates the component.
void	stop()	Deactivates and prepares the component for destruction.

Methods inherited from class java.lang.Object

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

Constructor Details

SocketLoggerAnalyticsConnectorPlugin

@Inject
public SocketLoggerAnalyticsConnectorPlugin(ParamManager paramManager,
 Optional<String> hostNameOpt,
 Optional<Integer> portOpt,
 Optional<String> hostNameParamOpt,
 Optional<String> portParamOpt,
 Optional<String> nodeNameParamOpt,
 Optional<String> envNameParamOpt,
 Optional<Integer> bufferSizeOpt,
 Optional<Integer> batchSizeOpt,
 Optional<Boolean> jsonLayoutOpt,
 Optional<String> jsonLayoutParamOpt,
 Optional<Boolean> compressOutputStreamOpt,
 Optional<String> compressOutputStreamParamOpt)

Constructor.

Parameters:

hostNameOpt - hostName of the remote server

portOpt - port of the remote server

bufferSizeOpt - size of the offline buffer in Mo

appNameOpt - the node name

Method Details

add

public void add(TraceSpan span)

Adds a span to a connector which acts as a consumer.

Specified by:

add in interface AnalyticsConnectorPlugin

Parameters:

span - the span

add

public void add(Metric metric)

Adds a metric to a connector which acts as a consumer.

Specified by:

add in interface AnalyticsConnectorPlugin

Parameters:

metric - the metric

add

public void add(HealthCheck healthCheck)

Adds a healthCheck to a connector which acts as a consumer.

Specified by:

add in interface AnalyticsConnectorPlugin

Parameters:

healthCheck - the healthCheck

start

public void start()

Description copied from interface: Activeable

Initializes and activates the component. This method is called after the component has been created and fully initialized, typically after dependency injection for components built via configuration. Implementations should perform any necessary setup or resource allocation to prepare the component for use.

Specified by:

start in interface Activeable

stop

public void stop()

Description copied from interface: Activeable

Deactivates and prepares the component for destruction. This method is called before the component is stopped or destroyed. Implementations should release resources, terminate processes, or perform cleanup to ensure a graceful shutdown.

Specified by:

stop in interface Activeable

pollQueue

public void pollQueue()

Daemon to unstack processes to end them