source

package

v1.3.3 Latest Latest Go to latest Published: Aug 13, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/open-ships/beacon

Links

Open Source Insights

Documentation ¶

Overview ¶

Package source runs configured sources and fans their envelopes out to subscribing connectors.

Index ¶

type Runtime
- func New(ctx context.Context, cfg model.Source, mgr *bus.Manager, log *slog.Logger, ...) (Runtime, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Runtime ¶

type Runtime interface {
	ID() string
	Subscribe(buf int) (<-chan *msg.Envelope, func())
	Stop()
	State() (string, error) // "up" | "degraded" | "error"
}

Runtime is a running source: it broadcasts envelopes to subscribers.

func New ¶

func New(ctx context.Context, cfg model.Source, mgr *bus.Manager, log *slog.Logger, met *metrics.Set, reg *stats.Registry) (Runtime, error)

New starts the source runtime for cfg. CAN types acquire from mgr; network types dial with jittered reconnect backoff (250ms→1m).

Source Files ¶

View all Source files

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