destrabbitmq

package

v0.6.1 Latest Latest Go to latest Published: Oct 6, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hookdeck/outpost

Links

Open Source Insights

Documentation ¶

Index ¶

type RabbitMQDestination
- func New(loader metadata.MetadataLoader, ...) (*RabbitMQDestination, error)
type RabbitMQDestinationConfig
type RabbitMQDestinationCredentials
type RabbitMQPublisher

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type RabbitMQDestination ¶

type RabbitMQDestination struct {
	*destregistry.BaseProvider
}

func New ¶

func New(loader metadata.MetadataLoader, basePublisherOpts []destregistry.BasePublisherOption) (*RabbitMQDestination, error)

func (*RabbitMQDestination) ComputeTarget ¶

func (d *RabbitMQDestination) ComputeTarget(destination *models.Destination) destregistry.DestinationTarget

func (*RabbitMQDestination) CreatePublisher ¶

func (d *RabbitMQDestination) CreatePublisher(ctx context.Context, destination *models.Destination) (destregistry.Publisher, error)

func (*RabbitMQDestination) Preprocess ¶

func (d *RabbitMQDestination) Preprocess(newDestination *models.Destination, originalDestination *models.Destination, opts *destregistry.PreprocessDestinationOpts) error

Preprocess sets the default TLS value to "true" if not provided

func (*RabbitMQDestination) Validate ¶

func (d *RabbitMQDestination) Validate(ctx context.Context, destination *models.Destination) error

type RabbitMQDestinationConfig ¶

type RabbitMQDestinationConfig struct {
	ServerURL string // TODO: consider renaming
	Exchange  string
	UseTLS    bool
}

type RabbitMQDestinationCredentials ¶

type RabbitMQDestinationCredentials struct {
	Username string
	Password string
}

type RabbitMQPublisher ¶

type RabbitMQPublisher struct {
	*destregistry.BasePublisher
	// contains filtered or unexported fields
}

func (*RabbitMQPublisher) Close ¶

func (p *RabbitMQPublisher) Close() error

func (*RabbitMQPublisher) ForceConnectionClose ¶

func (p *RabbitMQPublisher) ForceConnectionClose()

func (*RabbitMQPublisher) GetConnection ¶

func (p *RabbitMQPublisher) GetConnection() *amqp091.Connection

func (*RabbitMQPublisher) Publish ¶

func (p *RabbitMQPublisher) Publish(ctx context.Context, event *models.Event) (*destregistry.Delivery, error)

Source Files ¶

View all Source files

destrabbitmq.go

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