Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LauncherConsumer ¶
type LauncherConsumer struct {
// contains filtered or unexported fields
}
func NewLauncherConsumer ¶
func NewLauncherConsumer(log logutil.Log, db *sql.DB, runProducer *repoanalyzesqueue.Producer, pf providers.Factory) *LauncherConsumer
func (LauncherConsumer) Register ¶
func (c LauncherConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
type LauncherProducer ¶
func (LauncherProducer) Put ¶
func (p LauncherProducer) Put(repoID uint, commitSHA, analysisGUID string) error
func (*LauncherProducer) Register ¶
func (p *LauncherProducer) Register(m *producers.Multiplexer) error
Click to show internal directories.
Click to hide internal directories.