messaging

Documentation

Index

• Constants
• type Channels
  • func NewChannels() *Channels
• type Mailer
  • func NewMailer() *Mailer
  • func (m *Mailer) GetBody() string
  • func (m *Mailer) GetMimeHeaders() string
  • func (m *Mailer) GetSubject() string
  • func (m *Mailer) GetTo() string
  • func (m *Mailer) Send() error
  • func (m *Mailer) SetBody(body string)
  • func (m *Mailer) SetConfig(config map[string]string)
  • func (m *Mailer) SetMimeHeaders(mimeHeaders string)
  • func (m *Mailer) SetSubject(subject string)
  • func (m *Mailer) SetTo(to string)
• type Rabbit
  • func NewRabbit(file string) *Rabbit
  • func (r *Rabbit) Consume(queue string, callback func(amqp.Delivery)) error
  • func (r *Rabbit) DeclareExchange(exchange string) error
  • func (r *Rabbit) DeclareQueue(queue, exchange, routingKey string) error
  • func (r *Rabbit) Disconnect() error
  • func (r *Rabbit) IsConnected() bool
  • func (r *Rabbit) Publish(exchange, routingKey string, body []byte) error
  • func (r *Rabbit) PublishFromCache(messageService *migration.MessageService) error
• type RabbitConfig
  • func (r *RabbitConfig) LoadRabbitConfig(file string) error

Constants

const (
	MESSAGING_TIMEOUT = 30
)

Types

type Channels

type Channels struct {
	// Channel for sending messages to the messaging adapter
	SMS chan map[string]string
	// Channel for sending messages to the messaging adapter
	Email chan map[string]interface{}
	// Channel for sending messages to the messaging adapter
	Whatsapp chan map[string]interface{}
}

func NewChannels

func NewChannels() *Channels

type Mailer

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

func NewMailer

func NewMailer() *Mailer

func (*Mailer) GetBody

func (m *Mailer) GetBody() string

func (*Mailer) GetMimeHeaders

func (m *Mailer) GetMimeHeaders() string

func (*Mailer) GetSubject

func (m *Mailer) GetSubject() string

func (*Mailer) GetTo

func (m *Mailer) GetTo() string

func (*Mailer) Send

func (m *Mailer) Send() error

func (*Mailer) SetBody

func (m *Mailer) SetBody(body string)

func (*Mailer) SetConfig

func (m *Mailer) SetConfig(config map[string]string)

func (*Mailer) SetMimeHeaders

func (m *Mailer) SetMimeHeaders(mimeHeaders string)

func (*Mailer) SetSubject

func (m *Mailer) SetSubject(subject string)

func (*Mailer) SetTo

func (m *Mailer) SetTo(to string)

type Rabbit

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

func NewRabbit

func NewRabbit(file string) *Rabbit

func (*Rabbit) Consume

func (r *Rabbit) Consume(queue string, callback func(amqp.Delivery)) error

func (*Rabbit) DeclareExchange

func (r *Rabbit) DeclareExchange(exchange string) error

func (*Rabbit) DeclareQueue

func (r *Rabbit) DeclareQueue(queue, exchange, routingKey string) error

func (*Rabbit) Disconnect

func (r *Rabbit) Disconnect() error

func (*Rabbit) IsConnected

func (r *Rabbit) IsConnected() bool

func (*Rabbit) Publish

func (r *Rabbit) Publish(exchange, routingKey string, body []byte) error

func (*Rabbit) PublishFromCache

func (r *Rabbit) PublishFromCache(messageService *migration.MessageService) error

type RabbitConfig

type RabbitConfig struct {
	DSN string `json:"dsn"`
	// contains filtered or unexported fields
}

func (*RabbitConfig) LoadRabbitConfig

func (r *RabbitConfig) LoadRabbitConfig(file string) error