pubsub

type Message struct {
	// ID identifies this message.
	ID string `json:"id,omitempty"`

	// Data is the actual data in the entry.
	Data []byte `json:"data"`

	// Labels represents the key-value pairs the entry is labeled with.
	Labels map[string]string `json:"labels,omitempty"`
}

type Publisher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Receiver func(Message)