pkg/

directory
v1.0.0-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2023 License: Apache-2.0

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.
Package forward is used for creating a data forwarder for the map UDF and sink vertex.
Package forward is used for creating a data forwarder for the map UDF and sink vertex.
isb
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.
cmd
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
pbq/store/wal
Package wal implements write-ahead-log.
Package wal implements write-ahead-log.
pnf
Package pnf processes and then forwards messages belonging to a window.
Package pnf processes and then forwards messages belonging to a window.
shared
kvs
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.
tls
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.
udf
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.
keyed
Package keyed implements KeyedWindows.
Package keyed implements KeyedWindows.
strategy/fixed
Package fixed implements Fixed windows.
Package fixed implements Fixed windows.
strategy/sliding
Package sliding implements Sliding windows.
Package sliding implements Sliding windows.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL