zob

package
v0.0.0-...-a8e4d9d Latest Latest
Warning

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

Go to latest
Published: Jul 7, 2020 License: AGPL-3.0 Imports: 8 Imported by: 0

README

ZOB (Zentraler Omnibusbahnhof)

Routes pg create and change message to broadcast.create and broadcast.change amqp channels.

Usage:

$ HARROW_ENV=development zob

Requirements:

It requires that all messages published are JSON.

It won't inspect the bodies, but will add a Content-Type when forwarding to RabbitMQ where the Content-Type may be important.

Documentation

Index

Constants

View Source
const ProgramName = "zob"

Variables

This section is empty.

Functions

func Main

func Main()

Types

type ZOB

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

func NewZOB

func NewZOB(bus broadcast.Sink, datasource string) *ZOB

func (*ZOB) RouteMessages

func (self *ZOB) RouteMessages(pgChannelName string, kind broadcast.BroadcastMessageType)

Jump to

Keyboard shortcuts

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