package
Version:
v0.0.0-...-8c28d06
Opens a new window with list of versions in this module.
Published: Jul 12, 2019
License: MIT
Opens a new window with license information.
Imports: 4
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
Package broker provides chat broker functionality
Broker represents chat broker
New creates new chat broker instance
Send sends new message to a given chat
Subscribe subscribes to provided chat id at start sequence
Returns close subscription func, or an error.
SubscribeNew subscribes to provided chat id subject starting from time.Now()
Returns close subscription func, or an error.
ChatStore represents chat store interface
type Ingester interface {
Run(string) (func(), error)
}
Ingester represents chat history read model ingester
type MQ interface {
Send(string, []byte) error
SubscribeSeq(string, string, uint64, func(uint64, []byte)) (io.Closer, error)
SubscribeTimestamp(string, string, time.Time, func(uint64, []byte)) (io.Closer, error)
}
MQ represents message broker interface
Source Files
¶
Click to show internal directories.
Click to hide internal directories.