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/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. |
|
server/service/rater
Package rater provides the functionality to calculate the processing rate of each vertex partition.
|
Package rater provides the functionality to calculate the processing rate of each vertex partition. |
|
Package forwarder defines the interfaces for data forwarders in different type of vertices.
|
Package forwarder defines the interfaces for data forwarders in different type of vertices. |
|
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 and is responsible for the first part of reduce subsystem.
|
Package reduce reads messages from isb and is responsible for the first part of reduce subsystem. |
|
pbq/partition
Package partition is a tuple containing (start, end) time and an optional slot.
|
Package partition is a tuple containing (start, end) time and an optional slot. |
|
pbq/wal/aligned/fs
Package fs implements write-ahead-log on FileSystem.
|
Package fs implements write-ahead-log on FileSystem. |
|
pbq/wal/unaligned/fs
Package fs implements write-ahead-log on FileSystem.
|
Package fs implements write-ahead-log on FileSystem. |
|
shared
|
|
|
kvs/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. |
|
kvs/jetstream
Package jetstream package implements the kv store and watcher using Jetstream.
|
Package jetstream package implements the kv store and watcher using Jetstream. |
|
Package sideinputs is used for Side Inputs features.
|
Package sideinputs is used for Side Inputs features. |
|
initializer
Package initializer is used for init container on the vertex pod to initialize the Side Inputs data.
|
Package initializer is used for init container on the vertex pod to initialize the Side Inputs data. |
|
manager
Package manager is used for run the service in the numa container of a Side Inputs Manager.
|
Package manager is used for run the service in the numa container of a Side Inputs Manager. |
|
synchronizer
Package synchronizer is used for the service in the sidecar container of a vertex pod for watching Side Inputs data changes.
|
Package synchronizer is used for the service in the sidecar container of a vertex pod for watching Side Inputs data changes. |
|
forward
Package forward is used for creating a data forwarder for the source vertex.
|
Package forward is used for creating a data forwarder for the source vertex. |
|
generator
Package generator contains an implementation of an in-memory generator that generates payloads in json format.
|
Package generator contains an implementation of an in-memory generator that generates payloads in json format. |
|
udsource
Package udsource implements user-defined source, enabling the platform to communicate with user-defined data sources through gRPC.
|
Package udsource implements user-defined source, enabling the platform to communicate with user-defined data sources through gRPC. |
|
forward
Package forward is used for creating a data forwarder for the UDF vertex.
|
Package forward is used for creating a data forwarder for the UDF vertex. |
|
rpc
Package rpc provides the interface to invoke UDFs (map, mapstream and reduce).
|
Package rpc provides the interface to invoke UDFs (map, mapstream and reduce). |
|
watermark
|
|
|
entity
Package entity is the smallest processor entity for which the watermark will strictly monotonically increase.
|
Package entity is the smallest processor entity for which the watermark will strictly monotonically increase. |
|
wmb
Package wmb represents the offset-timeline pair and its corresponding encoder and decoder.
|
Package wmb represents the offset-timeline pair and its corresponding encoder and decoder. |
|
Package window implements windowing constructs.
|
Package window implements windowing constructs. |
|
strategy/fixed
Package fixed implements Fixed windows.
|
Package fixed implements Fixed windows. |
|
strategy/sliding
Package sliding implements Sliding windows.
|
Package sliding implements Sliding windows. |
Click to show internal directories.
Click to hide internal directories.