rabbit

package

v0.0.0-...-38323af Latest Latest Go to latest Published: Jun 10, 2021 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const ContentType = "text/json"

RabbitURI contains the connection url

This section is empty.

func Consumer(name int, input <-chan amqp.Delivery, out chan models.Record)

Consumer is a worker to receive and serialize messages

func ExtractCsvRecords(r io.Reader, out chan models.Record) int

ExtractCsvRecords receives a io.Reader and sends back csv records through a channel

func Publisher(name int, mq *RabbitMQ, input chan models.Record, wg *sync.WaitGroup)

type RabbitMQ struct {
	Conn    *amqp.Connection
	Channel *amqp.Channel
	Queue   amqp.Queue
}

Rabbit contains rabbitmq params

func Init(url string, queueName string) (*RabbitMQ, error)

Init setups RabbitMQ

func (r *RabbitMQ) Close()

Close RabbitMQ's amqp.Connection and amqp.Channel

func (r *RabbitMQ) PublishRecord(record models.Record) error

PublishRecord sends a record to queue with name equal to queue on channel