subs

Documentation

Index

• type CreatorConsumer
  • func NewCreatorConsumer(log logutil.Log, db *sql.DB, cfg config.Config, pp paymentproviders.Factory) *CreatorConsumer
  • func (cc CreatorConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
• type CreatorProducer
  • func (cp CreatorProducer) Put(subID uint) error
  • func (cp *CreatorProducer) Register(m *producers.Multiplexer) error
• type DeleterConsumer
  • func NewDeleterConsumer(log logutil.Log, db *sql.DB, cfg config.Config, pp paymentproviders.Factory) *DeleterConsumer
  • func (cc DeleterConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
• type DeleterProducer
  • func (cp DeleterProducer) Put(subID uint) error
  • func (cp *DeleterProducer) Register(m *producers.Multiplexer) error
• type UpdaterConsumer
  • func NewUpdaterConsumer(log logutil.Log, db *sql.DB, cfg config.Config, pp paymentproviders.Factory) *UpdaterConsumer
  • func (cc UpdaterConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error
• type UpdaterProducer
  • func (cp UpdaterProducer) Put(subID uint, seats int) error
  • func (cp *UpdaterProducer) 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, pp paymentproviders.Factory) *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(subID 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, pp paymentproviders.Factory) *DeleterConsumer

func (DeleterConsumer) Register

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

type DeleterProducer

type DeleterProducer struct {
	producers.Base
}

func (DeleterProducer) Put

func (cp DeleterProducer) Put(subID uint) error

func (*DeleterProducer) Register

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

type UpdaterConsumer

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

func NewUpdaterConsumer

func NewUpdaterConsumer(log logutil.Log, db *sql.DB, cfg config.Config, pp paymentproviders.Factory) *UpdaterConsumer

func (UpdaterConsumer) Register

func (cc UpdaterConsumer) Register(m *consumers.Multiplexer, df *redsync.Redsync) error

type UpdaterProducer

type UpdaterProducer struct {
	producers.Base
}

func (UpdaterProducer) Put

func (cp UpdaterProducer) Put(subID uint, seats int) error

func (*UpdaterProducer) Register

func (cp *UpdaterProducer) Register(m *producers.Multiplexer) error