messaging

Documentation

Index

• Constants
• func ConfigureDefault(config Config) (driver.Messaging, error)
• func ConfigureRabbitMQ(config Config) (driver.Messaging, error)
• func New(config Config) (driver.Messaging, error)
• type Config
• type Message
• type Table
  • func (t Table) Validate() error

Constants

const (
	DriverRabbitMQ = "rabbitmq"
)

Functions

func ConfigureDefault

func ConfigureDefault(config Config) (driver.Messaging, error)

func ConfigureRabbitMQ

func ConfigureRabbitMQ(config Config) (driver.Messaging, error)

func New

func New(config Config) (driver.Messaging, error)

Types

type Config

type Config struct {
	Driver string
	URL    string
}

type Message

type Message struct {
	Headers Table
	Tag     uint64
	Message []byte
}

type Table

type Table map[string]any

func (Table) Validate

func (t Table) Validate() error