Package ai.superstream

Class SuperstreamCounters

java.lang.Object

ai.superstream.SuperstreamCounters

public class SuperstreamCounters
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
long	TotalBytesAfterReduction
long	TotalBytesBeforeReduction
int	TotalMessagesFailedConsume
int	TotalMessagesFailedProduce
int	TotalMessagesSuccessfullyConsumed
int	TotalMessagesSuccessfullyProduce

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	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)

Methods inherited from class java.lang.Object

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

Field Details

TotalBytesBeforeReduction

public long TotalBytesBeforeReduction

TotalBytesAfterReduction

public long TotalBytesAfterReduction

TotalMessagesSuccessfullyProduce

public int TotalMessagesSuccessfullyProduce

TotalMessagesSuccessfullyConsumed

public int TotalMessagesSuccessfullyConsumed

TotalMessagesFailedProduce

public int TotalMessagesFailedProduce

TotalMessagesFailedConsume

public int TotalMessagesFailedConsume

Constructor Details

SuperstreamCounters

public SuperstreamCounters()

Method Details

reset

public void reset()

incrementTotalBytesBeforeReduction

public void incrementTotalBytesBeforeReduction(long bytes)

incrementTotalBytesAfterReduction

public void incrementTotalBytesAfterReduction(long bytes)

incrementTotalMessagesSuccessfullyProduce

public void incrementTotalMessagesSuccessfullyProduce()

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)