| Package | Description | 
|---|---|
| org.apache.storm.daemon.worker | |
| org.apache.storm.messaging | |
| org.apache.storm.messaging.netty | 
| Modifier and Type | Method and Description | 
|---|---|
BackPressureStatus | 
BackPressureTracker.getCurrStatus()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
IConnection.sendBackPressureStatus(BackPressureStatus bpStatus)
Sends the back pressure metrics to all downstream connections. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static BackPressureStatus | 
BackPressureStatus.read(byte[] bytes,
    KryoValuesDeserializer deserializer)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
BackPressureStatusEncoder.encode(org.apache.storm.shade.io.netty.channel.ChannelHandlerContext ctx,
      BackPressureStatus msg,
      List<Object> out)  | 
void | 
Client.sendBackPressureStatus(BackPressureStatus bpStatus)  | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.