Versions in this module Expand all Collapse all v1 v1.1.1 Jul 24, 2020 Changes in this version type Fields + func (f Fields) String() string v1.1.0 May 1, 2018 Changes in this version type Hub + func (h *Hub) With(f Fields) *Hub v1.0.0 Apr 28, 2018 Changes in this version + const AlertTopic + type AlertFunc func(missed int) + type Fields map[string]interface + type Hub struct + func New() *Hub + func (h *Hub) Close() + func (h *Hub) NonBlockingSubscribe(cap int, topics ...string) Subscription + func (h *Hub) Publish(m Message) + func (h *Hub) Subscribe(cap int, topics ...string) Subscription + func (h *Hub) Unsubscribe(sub Subscription) + type Message struct + Body []byte + Fields Fields + Name string + func (m *Message) Topic() string + type Subscription struct + Receiver <-chan Message + Topics []string
Go to main page