model

Documentation

Index

• func ConvertDeliveryToPublishing(message amqp.Delivery) amqp.Publishing
• func LoggedCloser(closer io.Closer)
• type AMQPClient
  • func GetAMQPClient(uri string) (client *AMQPClient, err error)
  • func (a *AMQPClient) ClientName() string
  • func (a *AMQPClient) Close()
  • func (a *AMQPClient) Consumer(queueName, topic, exchangeName string, retryDelay time.Duration) error
  • func (a *AMQPClient) Enabled() bool
  • func (a *AMQPClient) Listen(queue string) (<-chan amqp.Delivery, error)
  • func (a *AMQPClient) LoggedAck(message amqp.Delivery)
  • func (a *AMQPClient) LoggedReject(message amqp.Delivery, requeue bool)
  • func (a *AMQPClient) Ping() error
  • func (a *AMQPClient) Publish(payload amqp.Publishing, exchange string) error
  • func (a *AMQPClient) Publisher(exchangeName, exchangeType string, args amqp.Table) error
  • func (a *AMQPClient) Reconnect() error
  • func (a *AMQPClient) StopChannel()
  • func (a *AMQPClient) Vhost() string
• type Mail
• type MailRequest
  • func NewMailRequest() MailRequest
  • func (mr MailRequest) As(sender string) MailRequest
  • func (mr MailRequest) Check() error
  • func (mr MailRequest) ConvertToMail(content io.Reader) Mail
  • func (mr MailRequest) Data(payload interface{}) MailRequest
  • func (mr MailRequest) From(fromEmail string) MailRequest
  • func (mr MailRequest) Template(Tpl string) MailRequest
  • func (mr MailRequest) To(recipients ...string) MailRequest
  • func (mr MailRequest) WithSubject(subject string) MailRequest

Functions

func ConvertDeliveryToPublishing

func ConvertDeliveryToPublishing(message amqp.Delivery) amqp.Publishing

ConvertDeliveryToPublishing convert a delivery to a publishing, for requeuing

func LoggedCloser

func LoggedCloser(closer io.Closer)

LoggedCloser closes a ressources with handling error

Types

type AMQPClient

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

AMQPClient wraps all object required for AMQP usage

func GetAMQPClient

func GetAMQPClient(uri string) (client *AMQPClient, err error)

GetAMQPClient inits AMQP connection, channel and queue

func (*AMQPClient) ClientName

func (a *AMQPClient) ClientName() string

ClientName returns client name

func (*AMQPClient) Close

func (a *AMQPClient) Close()

Close closes opened ressources

func (*AMQPClient) Consumer

func (a *AMQPClient) Consumer(queueName, topic, exchangeName string, retryDelay time.Duration) error

Consumer configures client for consumming from given queue, bind to given exchange

func (*AMQPClient) Enabled

func (a *AMQPClient) Enabled() bool

Enabled checks if connection is setup

func (*AMQPClient) Listen

func (a *AMQPClient) Listen(queue string) (<-chan amqp.Delivery, error)

Listen listens to configured queue

func (*AMQPClient) LoggedAck

func (a *AMQPClient) LoggedAck(message amqp.Delivery)

LoggedAck ack a message with error handling

func (*AMQPClient) LoggedReject

func (a *AMQPClient) LoggedReject(message amqp.Delivery, requeue bool)

LoggedReject reject a message with error handling

func (*AMQPClient) Ping

func (a *AMQPClient) Ping() error

Ping checks if connection is live

func (*AMQPClient) Publish

func (a *AMQPClient) Publish(payload amqp.Publishing, exchange string) error

Publish sends payload to the underlying exchange

func (*AMQPClient) Publisher

func (a *AMQPClient) Publisher(exchangeName, exchangeType string, args amqp.Table) error

Publisher configures client for publishing to given exchange

func (*AMQPClient) Reconnect

func (a *AMQPClient) Reconnect() error

Reconnect to amqp

func (*AMQPClient) StopChannel

func (a *AMQPClient) StopChannel()

StopChannel cancel existing channel

func (*AMQPClient) Vhost

func (a *AMQPClient) Vhost() string

Vhost returns connection Vhost

type Mail

type Mail struct {
	From    string
	Sender  string
	Subject string
	Content io.Reader
	To      []string
}

Mail describe envelope of an email

type MailRequest

type MailRequest struct {
	Payload    interface{}
	Tpl        string
	FromEmail  string
	Sender     string
	Subject    string
	Recipients []string
}

MailRequest describes an email to be sent

func NewMailRequest

func NewMailRequest() MailRequest

NewMailRequest create a new email

func (MailRequest) As

func (mr MailRequest) As(sender string) MailRequest

As set sender

func (MailRequest) Check

func (mr MailRequest) Check() error

Check checks if current instance is valid

func (MailRequest) ConvertToMail

func (mr MailRequest) ConvertToMail(content io.Reader) Mail

ConvertToMail convert mail request to Mail with given content

func (MailRequest) Data

func (mr MailRequest) Data(payload interface{}) MailRequest

Data set payload

func (MailRequest) From

func (mr MailRequest) From(fromEmail string) MailRequest

From set from

func (MailRequest) Template

func (mr MailRequest) Template(Tpl string) MailRequest

Template set template

func (MailRequest) To

func (mr MailRequest) To(recipients ...string) MailRequest

To add recipients to list

func (MailRequest) WithSubject

func (mr MailRequest) WithSubject(subject string) MailRequest

WithSubject set subject