# Packages
No description provided by the author
# Functions
NewBroker creates a new broker instance that uses KubeMQ over gRPC streams.
WithAutoReconnect sets the auto reconnect flag.
WithClientID sets the client ID to be used when registering to KubeMQ server.
WithDeliveryTimeout sets the max execution time a handler has to process a message.
WithGroupID sets the group ID to be used when registering to KubeMQ server.
WithServerHost sets KubeMQ server host.
WithServerPort sets KubeMQ server grpc port.
WithStreamErrorHandler sets the function to be called when an error occurs when streaming events to KubeMQ (publish).
WithSubscribeErrorHandler sets the function to be called when an error occurs when receiving a message from KubeMQ.
# Interfaces
Option defines a function signature for configuration options.