sewer

package module
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Jul 23, 2019 License: MIT Imports: 3 Imported by: 0

README

sewer

Go Report Card Go Doc Release

sewer allows you to use go channels horizontally with the help of RabbitMQ

Getting Started

go get github.com/0x4139/sewer

Prerequisites

sewer only uses a dependency to "github.com/streadway/amqp"

module github.com/0x4139/sewer

go 1.12

require github.com/streadway/amqp v0.0.0-20190404075320-75d898a42a94

Installing

You can either use go get

go get github.com/0x4139/sewer

or go mod

go mod download  github.com/0x4139/sewer

Running the tests

#Testing using docker

If RabbitMQ is not installed on your machine, the easiest way to install it is using docker container.

Installing and running RabbitMQ without management tools plugin for the first time

docker run -d --hostname rabbitmq-test-host --name rabbitmq-test -p 5672:5672 -p 15672:15672 rabbitmq:3

Installing and running RabbitMQ with management tools plugin for the first time

docker run -d --hostname rabbitmq-test-host --name rabbitmq-test -p 5672:5672 -p 15672:15672 rabbitmq:3-management

Starting container

docker start rabbitmq-test

Running

From the working directory

go test

Contributing

Please read CONTRIBUTING.md for details on our code of conduct, and the process for submitting pull requests to us.

Versioning

We use SemVer for versioning. For the versions available, see the tags on this repository.

Authors

  • @Vali Malinoiu - Initial work - 0x4139

License

This project is licensed under the MIT License - see the LICENSE.md file for details

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Sewer

type Sewer struct {
	Name string
	// contains filtered or unexported fields
}

func New

func New(name, connectionString string) *Sewer

func (*Sewer) Close

func (s *Sewer) Close()

func (*Sewer) ErrorChannel

func (s *Sewer) ErrorChannel() <-chan error

func (*Sewer) Publisher

func (s *Sewer) Publisher() (chan []byte, error)

func (*Sewer) Subscriber

func (s *Sewer) Subscriber() (chan []byte, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL