dozer

package module

v0.0.0-...-f0caac9 Latest Latest Go to latest Published: Aug 1, 2018 License: BSD-3-Clause Imports: 2 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

Messaging abstractions written in Go.

Current platform support:

Dozer: main module

This section is empty.

This section is empty.

This section is empty.

type Dozer struct {
	// contains filtered or unexported fields
}

Core dozer type.

func Init(name string) *Dozer

Create a new Dozer instance.

func (d *Dozer) Consumer(dest string) *Dozer

Set destination in consumer mode

func (d *Dozer) Dial(host string, port int64) error

Connect or bind to a host and port.

func (d *Dozer) Producer(dest string) *Dozer

Set destination in producer mode

func (d *Dozer) RecvLoop(messages chan []byte, quit chan bool) error

Receive messages from the lower level protocol and forward them to a channel until a quit signal fires.

func (d *Dozer) SendLoop(messages chan []byte, quit chan bool) error

Send messages to the lower level protocol from a channel until a quit signal fires.

func (d *Dozer) WithCredentials(user, pass string) *Dozer

Set the auth credentials

Path	Synopsis
proto Dozer: protocol module	Dozer: protocol module
amqp Dozer: amqp protocol module	Dozer: amqp protocol module
kafka Dozer: kafka protocol module	Dozer: kafka protocol module
mangos Dozer: Mangos protocol module	Dozer: Mangos protocol module
nats Dozer: nats protocol module	Dozer: nats protocol module
stomp Dozer: stomp protocol module	Dozer: stomp protocol module