package
0.0.0-20201113072945-941bdb3e51a3
Repository: https://github.com/tuyainc/pulsar-client-go.git
Documentation: pkg.go.dev
# Functions
NewFrameDispatcher returns an instantiated FrameDispatcher.
# Structs
AsyncResp manages the state between a request and Response.
Dispatcher is Responsible for handling the request/Response state of outstanding requests.
Frame represents a pulsar message frame.
MockSender implements the sender interface.
prodSeqKey is a composite lookup key for the dispatchers that use producerID and sequenceID to correlate Responses, which are the SendReceipt and SendError Responses.
# Interfaces
CmdSender is an interface that is capable of sending commands to Pulsar.