package
0.0.0-20201113072945-941bdb3e51a3
Repository: https://github.com/tuyainc/pulsar-client-go.git
Documentation: pkg.go.dev
# Functions
NewUnexpectedErrMsg instantiates an ErrUnexpectedMsg error.
PulsarAddr is a helper function that either returns the non-blank pulsar address, or skips the test.
No description provided by the author
# Constants
authMethodTLS is the name of the TLS authentication method, used in the CONNECT message.
ClientVersion is an opaque string sent by the client to the server on connect, eg: "Pulsar-Client-Java-v1.15.2".
ProtoVersion is the Pulsar protocol version used by this client.
NndefRequestID defines a RequestID of -1.
# Structs
UnexpectedErrMsg is returned when an unexpected message is received.