amqp

package module
v6.0.0-beta.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 8, 2026 License: MIT Imports: 7 Imported by: 0

README

Documentation

Overview

Package amqp provides a RoadRunner plugin for AMQP (Advanced Message Queuing Protocol) integration. It enables RoadRunner's jobs system to use RabbitMQ or other AMQP-compatible message brokers as a backend for asynchronous job processing, supporting features like message persistence, routing, and reliable delivery.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Configurer

type Configurer interface {
	// UnmarshalKey takes a single key and unmarshal it into a Struct.
	UnmarshalKey(name string, out any) error
	// Has checks if a config section exists.
	Has(name string) bool
}

type Logger

type Logger interface {
	NamedLogger(name string) *zap.Logger
}

type Plugin

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

func (*Plugin) Collects

func (p *Plugin) Collects() []*dep.In

func (*Plugin) DriverFromConfig

func (p *Plugin) DriverFromConfig(configKey string, pq jobs.Queue, pipeline jobs.Pipeline) (jobs.Driver, error)

DriverFromConfig constructs amqp driver from the .rr.yaml configuration

func (*Plugin) DriverFromPipeline

func (p *Plugin) DriverFromPipeline(pipe jobs.Pipeline, pq jobs.Queue) (jobs.Driver, error)

DriverFromPipeline constructs amqp driver from pipeline

func (*Plugin) Init

func (p *Plugin) Init(log Logger, cfg Configurer) error

func (*Plugin) Name

func (p *Plugin) Name() string

type Tracer

type Tracer interface {
	Tracer() *sdktrace.TracerProvider
}

Directories

Path Synopsis
Package amqpjobs implements the AMQP driver for RoadRunner's jobs plugin.
Package amqpjobs implements the AMQP driver for RoadRunner's jobs plugin.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL