README
¶
Knative Eventing
This repository contains a work-in-progress eventing system that is designed to address a common need for cloud native development:
- Services are loosely coupled during development and deployed independently
- A producer can generate events before a consumer is listening, and a consumer can express an interest in an event or class of events that is not yet being produced.
- Services can be connected to create new applications
- without modifying producer or consumer, and
- with the ability to select a specific subset of events from a particular producer.
The high level mission of Knative Eventing is: Enable asynchronous application development through event delivery from anywhere.
For the full mission of Knative Eventing see docs/mission.md.
For complete Knative Eventing documentation, see Knative eventing or Knative docs to learn about Knative.
If you are interested in contributing, see CONTRIBUTING.md, DEVELOPMENT.md and Knative working groups.
Interested users should join knative-users.
Directories
¶
| Path | Synopsis |
|---|---|
|
cmd
|
|
|
apiserver_receive_adapter
command
|
|
|
appender
command
|
|
|
broker/filter
command
|
|
|
broker/ingress
command
|
|
|
controller
command
|
|
|
event_display
command
|
|
|
heartbeats
command
|
|
|
heartbeats_receiver
command
|
|
|
in_memory/channel_controller
command
|
|
|
in_memory/channel_dispatcher
command
|
|
|
mtchannel_broker
command
|
|
|
mtping
command
|
|
|
pong
command
Implements a simple utility function to demonstrate responses.
|
Implements a simple utility function to demonstrate responses. |
|
schema
command
|
|
|
sendevent
command
Implements a simple utility for sending a JSON-encoded sample event.
|
Implements a simple utility for sending a JSON-encoded sample event. |
|
sugar_controller
command
|
|
|
webhook
command
|
|
|
websocketsource
command
|
|
|
config
|
|
|
brokers/mt-channel-broker
Package broker is a placeholder that allows us to pull in config files via go mod vendor.
|
Package broker is a placeholder that allows us to pull in config files via go mod vendor. |
|
brokers/mt-channel-broker/deployments
Package deployments is a placeholder that allows us to pull in config files via go mod vendor.
|
Package deployments is a placeholder that allows us to pull in config files via go mod vendor. |
|
brokers/mt-channel-broker/roles
Package roles is a placeholder that allows us to pull in config files via go mod vendor.
|
Package roles is a placeholder that allows us to pull in config files via go mod vendor. |
|
channels/in-memory-channel
Package channel is a placeholder that allows us to pull in config files via go mod vendor.
|
Package channel is a placeholder that allows us to pull in config files via go mod vendor. |
|
channels/in-memory-channel/configmaps
Package configmaps is a placeholder that allows us to pull in config files via go mod vendor.
|
Package configmaps is a placeholder that allows us to pull in config files via go mod vendor. |
|
channels/in-memory-channel/deployments
Package deployments is a placeholder that allows us to pull in config files via go mod vendor.
|
Package deployments is a placeholder that allows us to pull in config files via go mod vendor. |
|
channels/in-memory-channel/resources
Package resources is a placeholder that allows us to pull in config files via go mod vendor.
|
Package resources is a placeholder that allows us to pull in config files via go mod vendor. |
|
channels/in-memory-channel/roles
Package roles is a placeholder that allows us to pull in config files via go mod vendor.
|
Package roles is a placeholder that allows us to pull in config files via go mod vendor. |
|
channels/in-memory-channel/webhooks
Package webhooks is a placeholder that allows us to pull in config files via go mod vendor.
|
Package webhooks is a placeholder that allows us to pull in config files via go mod vendor. |
|
core
Package core is a placeholder that allows us to pull in config files via go mod vendor.
|
Package core is a placeholder that allows us to pull in config files via go mod vendor. |
|
core/configmaps
Package configmaps is a placeholder that allows us to pull in config files via go mod vendor.
|
Package configmaps is a placeholder that allows us to pull in config files via go mod vendor. |
|
core/deployments
Package deployments is a placeholder that allows us to pull in config files via go mod vendor.
|
Package deployments is a placeholder that allows us to pull in config files via go mod vendor. |
|
core/resources
Package resources is a placeholder that allows us to pull in config files via go mod vendor.
|
Package resources is a placeholder that allows us to pull in config files via go mod vendor. |
|
core/roles
Package roles is a placeholder that allows us to pull in config files via go mod vendor.
|
Package roles is a placeholder that allows us to pull in config files via go mod vendor. |
|
core/webhooks
Package webhooks is a placeholder that allows us to pull in config files via go mod vendor.
|
Package webhooks is a placeholder that allows us to pull in config files via go mod vendor. |
|
post-install
Package post_install is a placeholder that allows us to pull in config files via go mod vendor.
|
Package post_install is a placeholder that allows us to pull in config files via go mod vendor. |
|
sugar
Package sugar is a placeholder that allows us to pull in config files via go mod vendor.
|
Package sugar is a placeholder that allows us to pull in config files via go mod vendor. |
|
pkg
|
|
|
apis/config
Package config holds the typed objects that define the schemas for ConfigMap objects that pertain to our API objects.
|
Package config holds the typed objects that define the schemas for ConfigMap objects that pertain to our API objects. |
|
apis/duck/v1
Package v1 is the v1 version of the API.
|
Package v1 is the v1 version of the API. |
|
apis/duck/v1alpha1
+k8s:deepcopy-gen=package +groupName=duck.knative.dev
|
+k8s:deepcopy-gen=package +groupName=duck.knative.dev |
|
apis/duck/v1beta1
Package v1beta1 is the v1beta1 version of the API.
|
Package v1beta1 is the v1beta1 version of the API. |
|
apis/eventing/v1
Package v1 is the v1 version of the API.
|
Package v1 is the v1 version of the API. |
|
apis/eventing/v1beta1
Package v1beta1 is the v1beta1 version of the API.
|
Package v1beta1 is the v1beta1 version of the API. |
|
apis/flows/v1
Package v1 is the v1 version of the API.
|
Package v1 is the v1 version of the API. |
|
apis/messaging/config
Package config holds the typed objects that define the schemas for ConfigMap objects that pertain to our API objects.
|
Package config holds the typed objects that define the schemas for ConfigMap objects that pertain to our API objects. |
|
apis/messaging/v1
Package v1 is the v1 version of the API.
|
Package v1 is the v1 version of the API. |
|
apis/sources/v1
Package v1 contains API Schema definitions for the sources v1 API group.
|
Package v1 contains API Schema definitions for the sources v1 API group. |
|
apis/sources/v1beta2
Package v1beta2 contains API Schema definitions for the sources v1beta2 API group.
|
Package v1beta2 contains API Schema definitions for the sources v1beta2 API group. |
|
channel/fanout
Package fanout provides an http.Handler that takes in one request and fans it out to N other requests, based on a list of Subscriptions.
|
Package fanout provides an http.Handler that takes in one request and fans it out to N other requests, based on a list of Subscriptions. |
|
channel/multichannelfanout
Package multichannelfanout provides an http.Handler that takes in one request to a Knative Channel and fans it out to N other requests.
|
Package multichannelfanout provides an http.Handler that takes in one request to a Knative Channel and fans it out to N other requests. |
|
client/clientset/versioned
This package has the automatically generated clientset.
|
This package has the automatically generated clientset. |
|
client/clientset/versioned/fake
This package has the automatically generated fake clientset.
|
This package has the automatically generated fake clientset. |
|
client/clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
|
This package contains the scheme of the automatically generated clientset. |
|
client/clientset/versioned/typed/eventing/v1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/eventing/v1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/eventing/v1beta1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/eventing/v1beta1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/flows/v1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/flows/v1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/messaging/v1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/messaging/v1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/sources/v1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/sources/v1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/sources/v1beta2
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/sources/v1beta2/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
reconciler/apiserversource
Package apiserversource implements the ApiSource controller.
|
Package apiserversource implements the ApiSource controller. |
|
reconciler/pingsource
Package controller implements the PingSource controller.
|
Package controller implements the PingSource controller. |
|
scheduler
The scheduler is responsible for placing virtual pod (VPod) replicas within real pods.
|
The scheduler is responsible for placing virtual pod (VPod) replicas within real pods. |
|
lib/recordevents/recorder_vent
Package recorder_vent implements an recordevents.EventLog backed by Kubernetes Events using an event recorder.
|
Package recorder_vent implements an recordevents.EventLog backed by Kubernetes Events using an event recorder. |
|
test_images/event-flaker
command
|
|
|
test_images/event-library
command
|
|
|
test_images/event-sender
command
|
|
|
test_images/heartbeats
command
|
|
|
test_images/performance
command
|
|
|
test_images/print
command
|
|
|
test_images/recordevents
command
|
|
|
test_images/request-sender
command
|
|
|
test_images/wathola-fetcher
command
|
|
|
test_images/wathola-forwarder
command
|
|
|
test_images/wathola-receiver
command
|
|
|
test_images/wathola-sender
command
|
|
Click to show internal directories.
Click to hide internal directories.