Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
func NewPublisher ¶
func NewPublisher(opts ...PublisherConfig) (*Publisher, error)
type PublisherConfig ¶
type PublisherConfig func(p *Publisher)
func PublisherBrokerAddress ¶
func PublisherBrokerAddress(addr string) PublisherConfig
func PublisherTopic ¶
func PublisherTopic(topic string) PublisherConfig
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func NewSubscriber ¶
func NewSubscriber(opts ...SubscriberConfig) (*Subscriber, error)
func (*Subscriber) Close ¶
func (s *Subscriber) Close()
func (*Subscriber) Read ¶
func (s *Subscriber) Read() ([]byte, error)
type SubscriberConfig ¶
type SubscriberConfig func(p *Subscriber)
func SubscriberBrokerAddress ¶
func SubscriberBrokerAddress(addr string) SubscriberConfig
func SubscriberTopic ¶
func SubscriberTopic(topic string) SubscriberConfig
Source Files
Click to show internal directories.
Click to hide internal directories.