utils

Documentation

Index

• Constants
• func PulsarAddr(t *testing.T) string
• func RandString(n int) string
• type AsyncErrors
  • func (a AsyncErrors) Send(err error)
• type UnexpectedErrMsg
  • func NewUnexpectedErrMsg(msgType api.BaseCommand_Type, ids ...interface{}) *UnexpectedErrMsg
  • func (e *UnexpectedErrMsg) Error() string

Constants

const (
	// ProtoVersion is the Pulsar protocol version
	// used by this client.
	ProtoVersion = int32(api.ProtocolVersion_v12)

	// ClientVersion is an opaque string sent
	// by the client to the server on connect, eg:
	// "Pulsar-Client-Java-v1.15.2"
	ClientVersion = "pulsar-client-go"

	// NndefRequestID defines a RequestID of -1.
	//
	// Usage example:
	// https://github.com/apache/incubator-pulsar/blob/fdc7b8426d8253c9437777ae51a4639239550f00/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java#L325
	UndefRequestID = 1<<64 - 1
)

const AuthMethodTLS = "tls"

authMethodTLS is the name of the TLS authentication method, used in the CONNECT message.

Functions

func PulsarAddr

func PulsarAddr(t *testing.T) string

PulsarAddr is a helper function that either returns the non-blank pulsar address, or skips the test.

func RandString

func RandString(n int) string

Types

type AsyncErrors

type AsyncErrors chan<- error

AsyncErrors provides idiom for sending in a non-blocking manner errors to a channel. Note: it's legal for asyncErrors to be nil

func (AsyncErrors) Send

func (a AsyncErrors) Send(err error)

Send places the error on the channel in a non-blocking way

type UnexpectedErrMsg

type UnexpectedErrMsg struct {
	// contains filtered or unexported fields
}

UnexpectedErrMsg is returned when an unexpected message is received.

func NewUnexpectedErrMsg

func NewUnexpectedErrMsg(msgType api.BaseCommand_Type, ids ...interface{}) *UnexpectedErrMsg

NewUnexpectedErrMsg instantiates an ErrUnexpectedMsg error. Optionally provide a list of IDs associated with the message for additional context in the error message.

func (*UnexpectedErrMsg) Error

func (e *UnexpectedErrMsg) Error() string

Error satisfies the error interface.