streams

package

v0.1.0 Latest Latest Go to latest Published: Feb 7, 2024 License: MIT Imports: 0 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

Package streams provides interfaces of the streaming library.

This section is empty.

This section is empty.

This section is empty.

type Flow interface {
	Inlet
	Outlet
	Via(Flow) Flow
	To(Sink)
}

Flow represents a set of stream processing steps that has one open input and one open output.

type Inlet interface {
	In() chan<- interface{}
}

Inlet represents a type that exposes one open input.

type Outlet interface {
	Out() <-chan interface{}
}

Outlet represents a type that exposes one open output.

type Sink interface {
	Inlet
}

Sink represents a set of stream processing steps that has one open input.

type Source interface {
	Outlet
	Via(Flow) Flow
}

Source represents a set of stream processing steps that has one open output.

Path	Synopsis
connector
extension Package extension provides basic connector implementations.	Package extension provides basic connector implementations.
kafka Package kafka implements the Apache Kafka connector.	Package kafka implements the Apache Kafka connector.
mongo
redis Package redis implements the Redis Pub/Sub connector.	Package redis implements the Redis Pub/Sub connector.
flow
util Package util provides utility functions.	Package util provides utility functions.
ospkg Package ospkg provides platform-specific utility functions and constants.	Package ospkg provides platform-specific utility functions and constants.
ws Package ws implements the WebSocket connector.	Package ws implements the WebSocket connector.