destrabbitmq

Documentation

Index

• type RabbitMQDestination
  • func New(loader metadata.MetadataLoader) (*RabbitMQDestination, error)
  • func (d *RabbitMQDestination) ComputeTarget(destination *models.Destination) string
  • func (d *RabbitMQDestination) CreatePublisher(ctx context.Context, destination *models.Destination) (destregistry.Publisher, error)
  • func (d *RabbitMQDestination) Validate(ctx context.Context, destination *models.Destination) error
• type RabbitMQDestinationConfig
• type RabbitMQDestinationCredentials
• type RabbitMQPublisher
  • func (p *RabbitMQPublisher) Close() error
  • func (p *RabbitMQPublisher) ForceConnectionClose()
  • func (p *RabbitMQPublisher) GetConnection() *amqp091.Connection
  • func (p *RabbitMQPublisher) Publish(ctx context.Context, event *models.Event) (*destregistry.Delivery, error)

Types

type RabbitMQDestination

type RabbitMQDestination struct {
	*destregistry.BaseProvider
}

func New

func New(loader metadata.MetadataLoader) (*RabbitMQDestination, error)

func (*RabbitMQDestination) ComputeTarget

func (d *RabbitMQDestination) ComputeTarget(destination *models.Destination) string

func (*RabbitMQDestination) CreatePublisher

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

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
	RoutingKey string
}

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)