common

package
v1.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 1, 2021 License: GPL-3.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrEmptyUrl = errors.New("empty string in url")
)
View Source 
var (
	ErrorBrokerDsnNotConfigured = errors.New("the rabbitMQ dsn url not configured")
)

Functions

This section is empty.

Types

type RabbitMqInterface added in v1.5.0 

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

func NewRabbitMq added in v1.5.0 

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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.