amqp

Documentation

Index

• type MailRequest
• type MailResponse
• type RabbitAMQPClient
  • func Get() *RabbitAMQPClient
  • func (r *RabbitAMQPClient) SendMail(msg []byte, cb func(MailResponse)) (string, error)
  • func (r *RabbitAMQPClient) SendSMS(msg []byte, cb func(SMSResponse)) (string, error)
  • func (a *RabbitAMQPClient) Stop()
  • func (a *RabbitAMQPClient) TrackEvent(e []byte, sender, name string) error
  • func (a *RabbitAMQPClient) Write(p []byte) (int, error)
• type SMSRequest
• type SMSResponse
• type TrackEvent

Types

type MailRequest

type MailRequest struct {
	From         string         `json:"from"`
	To           string         `json:"to"`
	Subject      string         `json:"subject"`
	DataMap      map[string]any `json:"data_map"`
	TemplateName string         `json:"template_name"`
	AckRequired  bool           `json:"ack_required"`
	Priority     string         `json:"priority"`
}

type MailResponse

type MailResponse struct {
	Status        bool   `json:"status"`
	Message       string `json:"message"`
	CorrelationId string `json:"correlation_id"`
}

type RabbitAMQPClient

type RabbitAMQPClient struct {
	Conn         *amqp.Connection
	Ch           *amqp.Channel
	LogExName    string // exchange name for logs
	TracExName   string // exchange name for tracker
	MailReqQName string // routing key for sending mail
	MailResQName string
	SMSReqQName  string // routing key for sending mail
	SMSResQName  string
}

func Get

func Get() *RabbitAMQPClient

func (*RabbitAMQPClient) SendMail

func (r *RabbitAMQPClient) SendMail(msg []byte, cb func(MailResponse)) (string, error)

func (*RabbitAMQPClient) SendSMS

func (r *RabbitAMQPClient) SendSMS(msg []byte, cb func(SMSResponse)) (string, error)

func (*RabbitAMQPClient) Stop

func (a *RabbitAMQPClient) Stop()

func (*RabbitAMQPClient) TrackEvent

func (a *RabbitAMQPClient) TrackEvent(e []byte, sender, name string) error

func (*RabbitAMQPClient) Write

func (a *RabbitAMQPClient) Write(p []byte) (int, error)

type SMSRequest

type SMSRequest struct {
	From         string         `json:"from"`
	To           string         `json:"to"`
	CountryCode  string         `json:"country_code"`
	Name         string         `json:"name"`
	Subject      string         `json:"subject"`
	DataMap      map[string]any `json:"data_map"`
	TemplateName string         `json:"template_name"`
	AckRequired  bool           `json:"ack_required"`
	Priority     string         `json:"priority"`
}

type SMSResponse

type SMSResponse struct {
	Status        bool   `json:"status"`
	Message       string `json:"message"`
	CorrelationId string `json:"correlation_id"`
}

type TrackEvent

type TrackEvent struct {
	Sender    string    `json:"sender"`
	EventName string    `json:"event_name"`
	EventData string    `json:"event_data"`
	CreatedAt time.Time `json:"created_at"`
}