rabbit

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

type ConnectorConfig struct {
	Name                 string `validate:"required"`
	ReconnectionAttempts int    `validate:"required,min=1"`
	URI                  struct {
		Host     string `validate:"required"`
		Port     int    `validate:"required,min=0"`
		Username string `validate:"required"`
		Password string `validate:"required"`
		Vhost    string `validate:"required"`

		CertFile   string // client TLS auth - path to certificate (PEM)
		CACertFile string // client TLS auth - path to CA certificate (PEM)
		KeyFile    string // client TLS auth - path to private key (PEM)
		ServerName string // client TLS auth - server name
	} `validate:"required"`

	Exchange         string
	UseDurableQueues bool
}

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

type NotificationHandler func(context.Context, amqp.Delivery)

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