repos

Documentation

Index

• type CreatorConsumer
  • func NewCreatorConsumer(log logutil.Log, db *sql.DB, cfg config.Config, pf providers.Factory, ...) *CreatorConsumer
  • func (cc CreatorConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
• type CreatorProducer
  • func (cp CreatorProducer) Put(repoID uint) error
  • func (cp *CreatorProducer) Register(m *producers.Multiplexer) error
• type DeleterConsumer
  • func NewDeleterConsumer(log logutil.Log, db *sql.DB, cfg config.Config, pf providers.Factory) *DeleterConsumer
  • func (dc DeleterConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
• type DeleterProducer
  • func (dp DeleterProducer) Put(repoID, userID uint) error
  • func (dp *DeleterProducer) Register(m *producers.Multiplexer) error

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

type CreatorProducer struct {
	producers.Base
}

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 NewDeleterConsumer(log logutil.Log, db *sql.DB, cfg config.Config, pf providers.Factory) *DeleterConsumer

func (DeleterConsumer) Register

func (dc DeleterConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error

type DeleterProducer

type DeleterProducer struct {
	producers.Base
}

func (DeleterProducer) Put

func (dp DeleterProducer) Put(repoID, userID uint) error

func (*DeleterProducer) Register

func (dp *DeleterProducer) Register(m *producers.Multiplexer) error