Documentation ¶
Overview ¶
Package streams specifies interfaces to be implemented by the streaming connectors and operators.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Flow ¶
Flow represents a set of stream processing steps that has one open input and one open output. Programs can combine multiple Flows into sophisticated dataflow topologies. Implement this interface to create a custom stream transformation operator.
type Inlet ¶
type Inlet interface {
In() chan<- any
}
Inlet represents a type that exposes one open input.
type Outlet ¶
type Outlet interface {
Out() <-chan any
}
Outlet represents a type that exposes one open output.
type Sink ¶
type Sink interface { Inlet }
Sink represents a set of stream processing steps that has one open input. A Sink will usually connect to a database or streaming platform to flush data from a pipeline. Implement this interface to create a custom sink connector.
Directories ¶
Path | Synopsis |
---|---|
aerospike
module
|
|
examples
module
|
|
Package extension provides basic connector implementations.
|
Package extension provides basic connector implementations. |
Package flow provides streams.Flow implementations.
|
Package flow provides streams.Flow implementations. |
internal
|
|
ospkg
Package ospkg provides platform-specific utility functions and constants.
|
Package ospkg provides platform-specific utility functions and constants. |
kafka
module
|
|
nats
module
|
|
pulsar
module
|
|
redis
module
|
|
websocket
module
|
|
ws
module
|