# Functions
NewBroker returns a new instance of a Broker with default values.
NewClient returns a new instance of Client.
NewClientConfig returns a new instance of ClientConfig.
NewHandler returns a new instance of Handler.
NewMessageDecoder returns a new instance of the MessageDecoder.
# Constants
BroadcastTopicID is the topic used to communicate with all replicas.
No description provided by the author
No description provided by the author
DefaultReconnectTimeout is the default time to wait between when a broker stream disconnects and another connection is retried.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Variables
ErrBrokerURLRequired is returned when opening a broker without URLs.
ErrClientClosed is returned when closing an already closed client.
ErrClientOpen is returned when opening an already open client.
ErrClosed is returned when closing a broker that's already closed.
ErrPathRequired is returned when opening a broker without a connection address.
ErrMessageTypeRequired is returned publishing a message without a type.
ErrPathRequired is returned when opening a broker without a path.
ErrReplicaExists is returned when creating a duplicate replica.
ErrReplicaIDRequired is returned when creating a replica without an id.
ErrReplicaNotFound is returned when referencing a replica that doesn't exist.
ErrSubscribed is returned when a stream is already subscribed to a topic.
ErrTopicExists is returned when creating a duplicate topic.
ErrTopicRequired is returned publishing a message without a topic ID.
# Structs
Broker represents distributed messaging system segmented into topics.
Client represents a client for the broker's HTTP API.
ClientConfig represents the Client configuration that must be persisted across restarts.
CreateReplica creates a new replica.
DeleteReplicaCommand removes a replica.
Handler represents an HTTP handler by the broker.
Message represents a single item in a topic.
MessageDecoder decodes messages from a reader.
Replica represents a collection of subscriptions to topics on the broker.
SubscribeCommand subscribes a replica to a new topic.
UnsubscribeCommand removes a subscription for a topic from a replica.
# Type aliases
MessageType represents the type of message.