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.md.
Interested users should join knative-users,
Directories
¶
| Path | Synopsis |
|---|---|
|
cmd
|
|
|
pong
Implements a simple utility function to demonstrate responses.
|
Implements a simple utility function to demonstrate responses. |
|
sendevent
Implements a simple utility for sending a JSON-encoded sample event.
|
Implements a simple utility for sending a JSON-encoded sample event. |
|
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. |
|
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/v0.15.0
Package postinstall is a placeholder that allows us to pull in config files via go mod vendor.
|
Package postinstall is a placeholder that allows us to pull in config files via go mod vendor. |
|
post-install/v0.16.0
Package preinstall is a placeholder that allows us to pull in config files via go mod vendor.
|
Package preinstall is a placeholder that allows us to pull in config files via go mod vendor. |
|
post-install/v0.17.0
Package preinstall is a placeholder that allows us to pull in config files via go mod vendor.
|
Package preinstall is a placeholder that allows us to pull in config files via go mod vendor. |
|
pre-install/v0.16.0
Package preinstall is a placeholder that allows us to pull in config files via go mod vendor.
|
Package preinstall is a placeholder that allows us to pull in config files via go mod vendor. |
|
pre-install/v0.18.0
Package preinstall is a placeholder that allows us to pull in config files via go mod vendor.
|
Package preinstall 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/configs/v1alpha1
Package v1alpha1 is the v1alpha1 version of the API.
|
Package v1alpha1 is the v1alpha1 version of the API. |
|
apis/duck/v1
Package v1 is the v1 version of the API.
|
Package v1 is the v1 version of the API. |
|
apis/duck/v1alpha1
Package v1alpha1 is the v1alpha1 version of the API.
|
Package v1alpha1 is the v1alpha1 version of the API. |
|
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/flows/v1beta1
Package v1beta1 is the v1beta1 version of the API.
|
Package v1beta1 is the v1beta1 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/messaging/v1beta1
Package v1beta1 is the v1beta1 version of the API.
|
Package v1beta1 is the v1beta1 version of the API. |
|
apis/sources/v1alpha1
Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:deepcopy-gen=package +groupName=sources.knative.dev
|
Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:deepcopy-gen=package +groupName=sources.knative.dev |
|
apis/sources/v1alpha2
Package v1alpha2 contains API Schema definitions for the sources v1beta1 API group +k8s:deepcopy-gen=package +groupName=sources.knative.dev
|
Package v1alpha2 contains API Schema definitions for the sources v1beta1 API group +k8s:deepcopy-gen=package +groupName=sources.knative.dev |
|
apis/sources/v1beta1
Package v1beta1 contains API Schema definitions for the sources v1beta1 API group.
|
Package v1beta1 contains API Schema definitions for the sources v1beta1 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. |
|
channel/swappable
Package swappable provides an http.Handler that delegates all HTTP requests to an underlying multichannelfanout.MessageHandler.
|
Package swappable provides an http.Handler that delegates all HTTP requests to an underlying multichannelfanout.MessageHandler. |
|
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/configs/v1alpha1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/configs/v1alpha1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
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/flows/v1beta1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/flows/v1beta1/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/messaging/v1beta1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/messaging/v1beta1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/sources/v1alpha1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/sources/v1alpha1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/sources/v1alpha2
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/sources/v1alpha2/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/sources/v1beta1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/sources/v1beta1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
kncloudevents
* Copyright 2020 The Knative Authors * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License.
|
* Copyright 2020 The Knative Authors * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. |
|
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. |
|
test/observer
Package observer is intended to be a utility that can observe CloudEvents as a Sink (addressable + CloudEvents) and fan out the observed events to several EventLog implementations if required.
|
Package observer is intended to be a utility that can observe CloudEvents as a Sink (addressable + CloudEvents) and fan out the observed events to several EventLog implementations if required. |
|
test/observer/http-vent
Package http_vent implements an observer.EventLog backed by a CloudEvents HTTP client, following the eventing sources container runtime contract.
|
Package http_vent implements an observer.EventLog backed by a CloudEvents HTTP client, following the eventing sources container runtime contract. |
|
test/observer/recorder-collector
Package recorder_collector holds a class to collect the logs from a recorder vented event log.
|
Package recorder_collector holds a class to collect the logs from a recorder vented event log. |
|
test/observer/recorder-vent
Package recorder_vent implements an observer.EventLog backed by Kubernetes Events using an event recorder.
|
Package recorder_vent implements an observer.EventLog backed by Kubernetes Events using an event recorder. |
|
test/observer/writer-vent
Package writer_vent implements an observer.EventLog backed by a io.Writer instance, events are converted to json and written out to the writer.
|
Package writer_vent implements an observer.EventLog backed by a io.Writer instance, events are converted to json and written out to the writer. |
|
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. |
Click to show internal directories.
Click to hide internal directories.