processor

Documentation

Index

• type Processor
  • func NewEqReceiptProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)
  • func NewFulfilmentConfirmedProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)
  • func NewOfflineReceiptProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)
  • func NewPpoUndeliveredProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)
  • func NewProcessor(ctx context.Context, appConfig *config.Configuration, pubSubProject string, ...) (*Processor, error)
  • func NewQmUndeliveredProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)
  • func (p *Processor) CloseRabbit()
  • func (p *Processor) Consume(ctx context.Context)
  • func (p *Processor) Process(_ context.Context, msg *pubsub.Message)

Types

type Processor

type Processor struct {
	RabbitConn         *amqp.Connection
	RabbitChannel      *amqp.Channel
	RabbitRoutingKey   string
	Config             *config.Configuration
	PubSubClient       *pubsub.Client
	PubSubSubscription *pubsub.Subscription

	ErrChan chan error
	Logger  *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewEqReceiptProcessor

func NewEqReceiptProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)

func NewFulfilmentConfirmedProcessor

func NewFulfilmentConfirmedProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)

func NewOfflineReceiptProcessor

func NewOfflineReceiptProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)

func NewPpoUndeliveredProcessor

func NewPpoUndeliveredProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)

func NewProcessor

func NewProcessor(ctx context.Context,
	appConfig *config.Configuration,
	pubSubProject string,
	pubSubSubscription string,
	routingKey string,
	messageConverter messageConverter,
	messageUnmarshaller messageUnmarshaller, errChan chan error) (*Processor, error)

func NewQmUndeliveredProcessor

func NewQmUndeliveredProcessor(ctx context.Context, appConfig *config.Configuration, errChan chan error) (*Processor, error)

func (*Processor) CloseRabbit

func (p *Processor) CloseRabbit()

func (*Processor) Consume

func (p *Processor) Consume(ctx context.Context)

func (*Processor) Process

func (p *Processor) Process(_ context.Context, msg *pubsub.Message)