Package org.apache.pulsar.common.policies.data

Class SinkStatus

java.lang.Object

org.apache.pulsar.common.policies.data.SinkStatus

public class SinkStatus
extends Object

Status of Pulsar Sink.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SinkStatus.SinkInstanceStatus	Status of a Sink instance.

Field Summary

Fields

Modifier and Type	Field	Description
List<SinkStatus.SinkInstanceStatus>	instances
int	numInstances
int	numRunning

Constructor Summary

Constructors

Constructor	Description
SinkStatus()

Method Summary

Modifier and Type	Method	Description
void	addInstance(SinkStatus.SinkInstanceStatus sinkInstanceStatus)

Methods inherited from class java.lang.Object

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

Field Details

numInstances

public int numInstances

numRunning

public int numRunning

instances

public List<SinkStatus.SinkInstanceStatus> instances

Constructor Details

SinkStatus

public SinkStatus()

Method Details

addInstance

public void addInstance(SinkStatus.SinkInstanceStatus sinkInstanceStatus)