Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CuratorBase ¶
type CuratorBase struct {
// contains filtered or unexported fields
}
CuratorBase manages communication between a curator and a message bus.
func New ¶
func New(curator curatoriface.Curator, messageBus messagebus.Sender) *CuratorBase
New returns a reference to a new CuratorBase instance.
func (*CuratorBase) Run ¶
func (c *CuratorBase) Run() (err error)
Run calls the underlaying curator's Curate method, and begins sending the resulting data stream to the message bus.
Source Files
Click to show internal directories.
Click to hide internal directories.