invitations

Documentation

Index

• type AcceptorConsumer
  • func NewAcceptorConsumer(log logutil.Log, cfg config.Config, pf providers.Factory) *AcceptorConsumer
  • func (c AcceptorConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
• type AcceptorProducer
  • func (p AcceptorProducer) Put(provider string, repo models.UniversalRepo, invitationID int) error
  • func (p *AcceptorProducer) Register(m *producers.Multiplexer) error

Types

type AcceptorConsumer

type AcceptorConsumer struct {
	// contains filtered or unexported fields
}

func NewAcceptorConsumer

func NewAcceptorConsumer(log logutil.Log, cfg config.Config, pf providers.Factory) *AcceptorConsumer

func (AcceptorConsumer) Register

func (c AcceptorConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error

type AcceptorProducer

type AcceptorProducer struct {
	producers.Base
}

func (AcceptorProducer) Put

func (p AcceptorProducer) Put(provider string, repo models.UniversalRepo, invitationID int) error

func (*AcceptorProducer) Register

func (p *AcceptorProducer) Register(m *producers.Multiplexer) error