destrabbitmq

Documentation

Index

• type RabbitMQDestination
  • func New(loader *metadata.MetadataLoader) (*RabbitMQDestination, error)
  • func (d *RabbitMQDestination) Publish(ctx context.Context, destination *models.Destination, event *models.Event) error
  • func (d *RabbitMQDestination) Validate(ctx context.Context, destination *models.Destination) error
• type RabbitMQDestinationConfig
• type RabbitMQDestinationCredentials

Types

type RabbitMQDestination

type RabbitMQDestination struct {
	*destregistry.BaseProvider
}

func New

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

func (*RabbitMQDestination) Publish

func (d *RabbitMQDestination) Publish(ctx context.Context, destination *models.Destination, event *models.Event) 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
}

type RabbitMQDestinationCredentials

type RabbitMQDestinationCredentials struct {
	Username string
	Password string
}