Package ai.superstream

Class SuperstreamCounters

java.lang.Object

ai.superstream.SuperstreamCounters

public class SuperstreamCounters
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
AtomicLong	TotalBytesAfterReduction
AtomicLong	TotalBytesBeforeReduction
AtomicInteger	TotalMessagesFailedConsume
AtomicInteger	TotalMessagesFailedProduce
AtomicInteger	TotalMessagesSuccessfullyConsumed
AtomicInteger	TotalMessagesSuccessfullyProduce
AtomicLong	TotalSSMPayloadReduced

Constructor Summary

Constructors

Constructor	Description
SuperstreamCounters()

Method Summary

Modifier and Type	Method	Description
long	getTotalBytesAfterReduction()
long	getTotalBytesBeforeReduction()
int	getTotalMessagesFailedConsume()
int	getTotalMessagesFailedProduce()
int	getTotalMessagesSuccessfullyConsumed()
int	getTotalMessagesSuccessfullyProduce()
void	incrementTotalBytesAfterReduction(long bytes)
void	incrementTotalBytesBeforeReduction(long bytes)
void	incrementTotalMessagesFailedConsume()
void	incrementTotalMessagesFailedProduce()
void	incrementTotalMessagesSuccessfullyConsumed()
void	incrementTotalMessagesSuccessfullyProduce()
void	incrementTotalSSMPayloadReduced(long bytes)
void	reset()
void	setTotalBytesAfterReduction(long totalBytesAfterReduction)
void	setTotalBytesBeforeReduction(long totalBytesBeforeReduction)
void	setTotalMessagesFailedConsume(int totalMessagesFailedConsume)
void	setTotalMessagesFailedProduce(int totalMessagesFailedProduce)
void	setTotalMessagesSuccessfullyConsumed(int totalMessagesSuccessfullyConsumed)
void	setTotalMessagesSuccessfullyProduce(int totalMessagesSuccessfullyProduce)
void	sumTotalBeforeReductionTotalSSMPayloadReduced()

Methods inherited from class java.lang.Object

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

Field Details

TotalBytesBeforeReduction

public AtomicLong TotalBytesBeforeReduction

TotalBytesAfterReduction

public AtomicLong TotalBytesAfterReduction

TotalMessagesSuccessfullyProduce

public AtomicInteger TotalMessagesSuccessfullyProduce

TotalMessagesSuccessfullyConsumed

public AtomicInteger TotalMessagesSuccessfullyConsumed

TotalMessagesFailedProduce

public AtomicInteger TotalMessagesFailedProduce

TotalMessagesFailedConsume

public AtomicInteger TotalMessagesFailedConsume

TotalSSMPayloadReduced

public AtomicLong TotalSSMPayloadReduced

Constructor Details

SuperstreamCounters

public SuperstreamCounters()

Method Details

reset

public void reset()

incrementTotalBytesBeforeReduction

public void incrementTotalBytesBeforeReduction(long bytes)

incrementTotalBytesAfterReduction

public void incrementTotalBytesAfterReduction(long bytes)

incrementTotalSSMPayloadReduced

public void incrementTotalSSMPayloadReduced(long bytes)

incrementTotalMessagesSuccessfullyProduce

public void incrementTotalMessagesSuccessfullyProduce()

sumTotalBeforeReductionTotalSSMPayloadReduced

public void sumTotalBeforeReductionTotalSSMPayloadReduced()

incrementTotalMessagesSuccessfullyConsumed

public void incrementTotalMessagesSuccessfullyConsumed()

incrementTotalMessagesFailedProduce

public void incrementTotalMessagesFailedProduce()

incrementTotalMessagesFailedConsume

public void incrementTotalMessagesFailedConsume()

getTotalBytesBeforeReduction

public long getTotalBytesBeforeReduction()

getTotalBytesAfterReduction

public long getTotalBytesAfterReduction()

getTotalMessagesSuccessfullyProduce

public int getTotalMessagesSuccessfullyProduce()

getTotalMessagesSuccessfullyConsumed

public int getTotalMessagesSuccessfullyConsumed()

getTotalMessagesFailedProduce

public int getTotalMessagesFailedProduce()

getTotalMessagesFailedConsume

public int getTotalMessagesFailedConsume()

setTotalBytesBeforeReduction

public void setTotalBytesBeforeReduction(long totalBytesBeforeReduction)

setTotalBytesAfterReduction

public void setTotalBytesAfterReduction(long totalBytesAfterReduction)

setTotalMessagesSuccessfullyProduce

public void setTotalMessagesSuccessfullyProduce(int totalMessagesSuccessfullyProduce)

setTotalMessagesSuccessfullyConsumed

public void setTotalMessagesSuccessfullyConsumed(int totalMessagesSuccessfullyConsumed)

setTotalMessagesFailedProduce

public void setTotalMessagesFailedProduce(int totalMessagesFailedProduce)

setTotalMessagesFailedConsume

public void setTotalMessagesFailedConsume(int totalMessagesFailedConsume)