pkg/

directory
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Aug 2, 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 does the Read (fromBufferPartition) -> Process (UDF) -> Forward (toBuffers) -> Ack (fromBufferPartition) loop.
Package forward does the Read (fromBufferPartition) -> Process (UDF) -> Forward (toBuffers) -> Ack (fromBufferPartition) loop.
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.
sdkclient
shared
tls
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.
udf
watermark
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.
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