Categorygithub.com/edgeflare/pgopkgpipeline
package
0.0.0-20250106230832-9a330938ded7
Repository: https://github.com/edgeflare/pgo.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
5
Dependents
8
Files
116 SLOC

# Packages

No description provided by the author
No description provided by the author

# Functions

Manager returns the singleton Manager instance.
RegisterConnector adds a new connector to the registry.

# Constants

Predefined connectors.
Predefined connectors.
Predefined connectors.
Predefined connectors.
Predefined connectors.
Predefined connectors.
Sink / consumer-only.
Source and sink.
Source / producer-only.
No description provided by the author
Predefined connectors.

# Variables

No description provided by the author

# Structs

Mngr (Manager) handles connectors and peers for data pipeline operations.
Peer is a data source/destination with an associated connector (ie ClickHouse, Kafka, MQTT, etc).

# Interfaces

A Connector represents a data pipeline component.

# Type aliases

No description provided by the author