public interface NettyConnectionWriter
NettyConnectionWriter
is used by TierProducerAgent
to write buffers to netty
connection. Buffers in the writer will be written to a queue structure and netty server will send
buffers from it.Modifier and Type | Method and Description |
---|---|
void |
close(Throwable error)
If error is null, remove and recycle all buffers in the writer.
|
NettyConnectionId |
getNettyConnectionId()
Get the id of connection in the writer.
|
void |
notifyAvailable()
Notify the buffer is available in writer.
|
int |
numQueuedBufferPayloads()
Get the number of written but unsent buffer netty payloads.
|
int |
numQueuedPayloads()
Get the number of written but unsent netty payloads.
|
void |
writeNettyPayload(NettyPayload nettyPayload)
Write a buffer to netty connection.
|
void writeNettyPayload(NettyPayload nettyPayload)
nettyPayload
- the payload send to netty connection.NettyConnectionId getNettyConnectionId()
void notifyAvailable()
int numQueuedPayloads()
int numQueuedBufferPayloads()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.