Documentation ¶
Overview ¶
Package streams provides interfaces of the streaming library.
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.
type Inlet ¶
type Inlet interface {
In() chan<- interface{}
}
Inlet represents a type that exposes one open input.
type Outlet ¶
type Outlet interface {
Out() <-chan interface{}
}
Outlet represents a type that exposes one open output.
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. |
kafka
module
|
|
nats
module
|
|
pulsar
module
|
|
redis
module
|
|
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. |
websocket
module
|
|
ws
module
|
Click to show internal directories.
Click to hide internal directories.