public interface NettyServiceProducer
NettyServiceProducer
is used as the callback to register NettyConnectionWriter
and disconnect netty connection in TierProducerAgent
.Modifier and Type | Method and Description |
---|---|
void |
connectionBroken(NettyConnectionId connectionId)
NettyConnectionWriter related to a connection id will be notified when the netty
connection is broken. |
void |
connectionEstablished(TieredStorageSubpartitionId subpartitionId,
NettyConnectionWriter nettyConnectionWriter)
NettyConnectionWriter will be created when a netty connection is established for a
subpartition. |
void connectionEstablished(TieredStorageSubpartitionId subpartitionId, NettyConnectionWriter nettyConnectionWriter)
NettyConnectionWriter
will be created when a netty connection is established for a
subpartition.subpartitionId
- subpartition id indicates the id of subpartition.nettyConnectionWriter
- writer is used to write buffers to netty connection.void connectionBroken(NettyConnectionId connectionId)
NettyConnectionWriter
related to a connection id will be notified when the netty
connection is broken.connectionId
- connection id is the id of connection.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.