# Functions
InitPipeline create and init pipeline with initializer.
NewAckManager will create a instance of default implementation of AckManage.
No description provided by the author
NewHashSafeChannelGroup create a instance of ChannelGroup based on hash-table.
# Variables
No description provided by the author
No description provided by the author
Errors.
Errors.
Errors.
Errors.
Errors.
# Structs
FunctionalChannelHandler is a public implementation of ChannelHandler interface which support functional definition for business logic.
FunctionalPipelineInitializer is a public implementation of PipelineInitializer interface which support functional definition for pipeline initialization logic.
No description provided by the author
SafeAckManager is a parallel-safe implementation of AckManager interface.
No description provided by the author
# Interfaces
AckManager is the interface wraps methods for acknowledgement management.
No description provided by the author
ChannelGroup is a interface wraps methods for channel management which provide batch close support for channels.
ChannelHandler is the interface provide necessary methods for channel event handle which invoked by pipeline.
Pipeline is the interface defined necessary methods which makes a pipeline of FrameDecoder, FrameEncoder, and ChannelHandler for inbound and outbound data processing.
ChannelHandler is the interface provide necessary methods for pipeline initialization which invoked by pipeline.
No description provided by the author