sinks

package

v0.0.0-...-db3f45c Latest Latest Go to latest Published: Apr 26, 2024 License: Apache-2.0, BSD-3-Clause, MIT Imports: 5 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

This section is empty.

This section is empty.

This section is empty.

type EnvelopeSender interface {
	SendTo(string, *events.Envelope)
}

EnvelopeSender is the interface the MessageRouter uses to send envelopes read from the diode.

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

MessageRouter consumes from a diode and sends envelopes to all recipients passed to the NewMessageRouter constructor.

func NewMessageRouter(e ...EnvelopeSender) *MessageRouter

NewMessageRouter is the preferred means of constructing a MessageRouter.

func (r *MessageRouter) Start(incomingLog *diodes.ManyToOneEnvelope)

Start begins an infinite loop which reads from the diode and sends any received envelopes to the MessageRouter's senders.