Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CreatorConsumer ¶
type CreatorConsumer struct {
// contains filtered or unexported fields
}
func NewCreatorConsumer ¶
func NewCreatorConsumer(log logutil.Log, db *sql.DB, cfg config.Config, pf providers.Factory, alq *repoanalyzes.LauncherProducer, invq *invitations.AcceptorProducer) *CreatorConsumer
func (CreatorConsumer) Register ¶
func (cc CreatorConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
type CreatorProducer ¶
func (CreatorProducer) Put ¶
func (cp CreatorProducer) Put(repoID uint) error
func (*CreatorProducer) Register ¶
func (cp *CreatorProducer) Register(m *producers.Multiplexer) error
type DeleterConsumer ¶
type DeleterConsumer struct {
// contains filtered or unexported fields
}
func NewDeleterConsumer ¶
func (DeleterConsumer) Register ¶
func (dc DeleterConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
type DeleterProducer ¶
func (DeleterProducer) Put ¶
func (dp DeleterProducer) Put(repoID, userID uint) error
func (*DeleterProducer) Register ¶
func (dp *DeleterProducer) Register(m *producers.Multiplexer) error
Source Files
Click to show internal directories.
Click to hide internal directories.