pkg/

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

Links

Open Source Insights

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.
informers/externalversions
informers/externalversions/internalinterfaces
informers/externalversions/numaflow
informers/externalversions/numaflow/v1alpha1
listers/numaflow/v1alpha1
daemon
client
server
server/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.
jetstream
redis
simplebuffer
testutils
isbsvc
clients
metrics
shared
expr
logging
queue
tls
util
sinks
kafka
logger
udsink
sources
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.
http
kafka
udf
applier
builtin
builtin/cat
builtin/filter
watermark
fetch
generic
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.
publish
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.
store/noop

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