Record Class KafkaStreamsRuntimeState

java.lang.Object

java.lang.Record

io.micronaut.controlpanel.panels.kafka.KafkaStreamsRuntimeState

Record Components:

available - whether runtime details are visible through Health

status - health status for the Kafka Streams application

message - optional runtime-state message

threads - stream thread runtime details

hasThreads - whether stream thread details are present

@Internal
public record KafkaStreamsRuntimeState(boolean available, String status, String message, List<KafkaStreamsRuntimeState.ThreadState> threads, boolean hasThreads)
extends Record

Runtime state exposed by Micronaut Health for a Kafka Streams application.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	KafkaStreamsRuntimeState.TaskSummary	Summary of a Kafka Streams task set.
static final record	KafkaStreamsRuntimeState.ThreadState	Runtime state for one Kafka Streams thread.

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsRuntimeState(boolean available, String status, String message, List<KafkaStreamsRuntimeState.ThreadState> threads, boolean hasThreads)	Creates an instance of a KafkaStreamsRuntimeState record class.

Method Summary

Modifier and Type	Method	Description
boolean	available()	Returns the value of the available record component.
final boolean	equals(Object o)	Indicates whether some other object is "equal to" this one.
boolean	errorState()
final int	hashCode()	Returns a hash code value for this object.
boolean	hasThreads()	Returns the value of the hasThreads record component.
String	message()	Returns the value of the message record component.
String	sectionStateClass()
String	status()	Returns the value of the status record component.
String	statusBadgeClass()
List<KafkaStreamsRuntimeState.ThreadState>	threads()	Returns the value of the threads record component.
final String	toString()	Returns a string representation of this record class.

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

KafkaStreamsRuntimeState

public KafkaStreamsRuntimeState(boolean available,
 String status,
 String message,
 List<KafkaStreamsRuntimeState.ThreadState> threads,
 boolean hasThreads)

Creates an instance of a KafkaStreamsRuntimeState record class.

Parameters:

available - the value for the available record component

status - the value for the status record component

message - the value for the message record component

threads - the value for the threads record component

hasThreads - the value for the hasThreads record component

Method Details

statusBadgeClass

public String statusBadgeClass()

Returns:

badge class for the overall runtime status

sectionStateClass

public String sectionStateClass()

Returns:

state class for runtime section rendering

errorState

public boolean errorState()

Returns:

whether Health reports a non-healthy status for this Kafka Streams application

toString

public final String toString()

Returns a string representation of this record class. The representation contains the name of the class, followed by the name and value of each of the record components.

Specified by:

toString in class Record

Returns:

a string representation of this object

hashCode

public final int hashCode()

Returns a hash code value for this object. The value is derived from the hash code of each of the record components.

Specified by:

hashCode in class Record

Returns:

a hash code value for this object

equals

public final boolean equals(Object o)

Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. Reference components are compared with Objects::equals(Object,Object); primitive components are compared with the compare method from their corresponding wrapper classes.

Specified by:

equals in class Record

Parameters:

o - the object with which to compare

Returns:

true if this object is the same as the o argument; false otherwise.

available

public boolean available()

Returns the value of the available record component.

Returns:

the value of the available record component

status

public String status()

Returns the value of the status record component.

Returns:

the value of the status record component

message

public String message()

Returns the value of the message record component.

Returns:

the value of the message record component

threads

public List<KafkaStreamsRuntimeState.ThreadState> threads()

Returns the value of the threads record component.

Returns:

the value of the threads record component

hasThreads

public boolean hasThreads()

Returns the value of the hasThreads record component.

Returns:

the value of the hasThreads record component