Directories
¶
| Path | Synopsis |
|---|---|
|
apis
|
|
|
numaflow/v1alpha1
+kubebuilder:object:generate=true +groupName=numaflow.numaproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true
|
+kubebuilder:object:generate=true +groupName=numaflow.numaproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true |
|
proto/daemon
Package daemon is a reverse proxy.
|
Package daemon is a reverse proxy. |
|
client
|
|
|
clientset/versioned
This package has the automatically generated clientset.
|
This package has the automatically generated clientset. |
|
clientset/versioned/fake
This package has the automatically generated fake clientset.
|
This package has the automatically generated fake clientset. |
|
clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
|
This package contains the scheme of the automatically generated clientset. |
|
clientset/versioned/typed/numaflow/v1alpha1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
clientset/versioned/typed/numaflow/v1alpha1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
daemon
|
|
|
server/service
Package service is built for querying metadata and to expose it over daemon service.
|
Package service is built for querying metadata and to expose it over daemon service. |
|
forward
Package forward does the Read (fromBuffer) -> Process (UDF) -> Forward (toBuffers) -> Ack (fromBuffer) loop.
|
Package forward does the Read (fromBuffer) -> Process (UDF) -> Forward (toBuffers) -> Ack (fromBuffer) loop. |
|
store/wal
Package wal implements write-ahead-log.
|
Package wal implements write-ahead-log. |
|
Package reconciler defines implementations of the Reconciler interface defined at sigs.k8s.io/controller-runtime/pkg/reconcile.Reconciler.
|
Package reconciler defines implementations of the Reconciler interface defined at sigs.k8s.io/controller-runtime/pkg/reconcile.Reconciler. |
|
vertex/scaling
Package scaling provides the autoscaling capability for Numaflow.
|
Package scaling provides the autoscaling capability for Numaflow. |
|
Package reduce reads messages from isb attaches watermark to read messages invoke the read-loop with the read messages
|
Package reduce reads messages from isb attaches watermark to read messages invoke the read-loop with the read messages |
|
pnf
Package pnf processes and then forwards messages belonging to a window.
|
Package pnf processes and then forwards messages belonging to a window. |
|
readloop
Package readloop is responsible for the first part of reduce subsystem.
|
Package readloop is responsible for the first part of reduce subsystem. |
|
shared
|
|
|
clients/jetstream
Package jetstream provides interface and two implementations to connect Nats JetStream.
|
Package jetstream provides interface and two implementations to connect Nats JetStream. |
|
generator
Package generator contains an implementation of a in memory generator that generates payloads in json format.
|
Package generator contains an implementation of a in memory generator that generates payloads in json format. |
|
function
Package funcmock is a generated GoMock package.
|
Package funcmock is a generated GoMock package. |
|
watermark
|
|
|
ot
Package ot represents the offset-timeline pair and its corresponding encoder and decoder.
|
Package ot represents the offset-timeline pair and its corresponding encoder and decoder. |
|
processor
Package processor is the smallest processor entity for which the watermark will strictly monotonically increase.
|
Package processor is the smallest processor entity for which the watermark will strictly monotonically increase. |
|
store/inmem
Package inmem package implements the watermark progression using in mem store as the KV store.
|
Package inmem package implements the watermark progression using in mem store as the KV store. |
|
store/jetstream
Package jetstream package implements the watermark progression using Jetstream as the KV store.
|
Package jetstream package implements the watermark progression using Jetstream as the KV store. |
|
Package window implements windowing constructs.
|
Package window implements windowing constructs. |
|
keyed
Package keyed implements KeyedWindows.
|
Package keyed implements KeyedWindows. |
|
strategy/fixed
Package fixed implements Fixed windows.
|
Package fixed implements Fixed windows. |
Click to show internal directories.
Click to hide internal directories.