paymentevents

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(provider, payload string) error
  • func (cp *CreatorProducer) 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(provider, payload string) error

func (*CreatorProducer) Register

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