pkg/

directory
v0.6.4 Latest Latest
Warning

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

Go to latest
Published: Nov 29, 2022 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.
isb
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.
pbq
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.
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 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.
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
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.

Jump to

Keyboard shortcuts

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