bridge

Documentation

Index

• Variables
• type AMQPConsumer
  • func NewAMQPConsumer(ctx context.Context, url string, queues []Queue, log logger) *AMQPConsumer
  • func (c *AMQPConsumer) Stop()
• type Processor
  • func NewExecProcessor(cmd string, args ...string) Processor
  • func NewFastCGIProcessor(net, addr, script string, log logger) Processor
  • func ProcessorWithEnv(p Processor, env map[string]string) Processor
• type Queue

Variables

var ErrProcessingError = errors.New("request to processing backend has failed (response status code 3xx or 4xx)")

var ErrProcessingFailed = errors.New("message processing failed (response status code 5xx)")

var ErrProcessorInternal = errors.New("processor was not able to perform request")

var ErrUnknownStatus = errors.New("processor was not able to read response status code")

Types

type AMQPConsumer

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

func NewAMQPConsumer

func NewAMQPConsumer(ctx context.Context, url string, queues []Queue, log logger) *AMQPConsumer

NewAMQPConsumer constructs AMQP consumer and starts message processing routine

func (*AMQPConsumer) Stop

func (c *AMQPConsumer) Stop()

Stop AMQP consumer and wait for all routines to gracefully finish

type Processor

type Processor func(ctx context.Context, headers map[string]string, body []byte) error

func NewExecProcessor

func NewExecProcessor(cmd string, args ...string) Processor

func NewFastCGIProcessor

func NewFastCGIProcessor(net, addr, script string, log logger) Processor

func ProcessorWithEnv

func ProcessorWithEnv(p Processor, env map[string]string) Processor

type Queue

type Queue struct {
	Name           string
	Prefetch       int
	Parallelism    int
	FailureTimeout time.Duration
	Processor      Processor
}