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 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.
stores/jetstream
stores/redis
stores/simplebuffer
testutils
isbsvc
metrics
pbq
store
store/memory
store/noop
util
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.
clients/redis
expr
logging
queue
tls
util
shuffle
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
generic/jetstream
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
window Package window implements windowing constructs.	Package window implements windowing constructs.
keyed
strategy/fixed Package fixed implements Fixed windows.	Package fixed implements Fixed windows.

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