common

Documentation

Index

• Variables
• type RabbitMqInterface
  • func NewRabbitMq(dsn string) (RabbitMqInterface, error)
• type Request
• type Response

Variables

var (
	ErrEmptyUrl = errors.New("empty string in url")
)

var (
	ErrorBrokerDsnNotConfigured = errors.New("the rabbitMQ dsn url not configured")
)

Types

type RabbitMqInterface

type RabbitMqInterface interface {
	NewBroker(topic string, queueArgs amqp.Table, fn interface{}) (rabbitmq.BrokerInterface, error)
}

func NewRabbitMq

func NewRabbitMq(dsn string) (RabbitMqInterface, error)

type Request

type Request struct {
	Headers map[string]string `json:"headers"`
	Body    interface{}       `json:"body"`
}

type Response

type Response struct {
	Headers map[string]string `json:"headers"`
	Body    interface{}       `json:"body"`
	Status  int               `json:"status"`
}