bridge

package

v0.0.0-...-81c1230 Latest Latest Go to latest Published: Jul 17, 2018 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

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

View Source

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

View Source

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

View Source

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

This section is empty.

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

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

NewAMQPConsumer constructs AMQP consumer and starts message processing routine

func (c *AMQPConsumer) Stop()

Stop AMQP consumer and wait for all routines to gracefully finish

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

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 struct {
	Name           string
	Prefetch       int
	Parallelism    int
	FailureTimeout time.Duration
	Processor      Processor
}