dispatch/pkg/events · dispatch1/dispatch

29192f92创建于 2018年7月4日历史提交

文件	最后提交记录	最后更新时间
driverclient	Add support for CloudEvents and event driver sidecar (#244) List of changes: * Added support for CloudEvent - all events must now follow this spec * Added new concept - event driver sidecar. * RabbitMQ is abstracted into transport package and interface. Adding support for Kafka is planned * Example ticker event driver based on new concept added to examples * Added initial support for OpenTracing * A lot of minor tweaks and fixed golint issues	8 年前
mocks	Make the event transport compatible with recent multi-org changes (#531) * Transport interface now expects organization for both Publish and Subscribe methods. For both Kafka and RabbitMQ, organization is prepended to the topic. This has certain implications on organization name/allowed characters. If this becomes a problem, we should consider using some other Organization ID. * RabbitMQ now uses single Exchange. Previous approach was to declare separate Exchange for each organization, but this would require event manager to listen on changes in Organization entities. For now, a simpler approach of using single exchange and prepending the org to the topic is used. * Cosmetic improvements in error handling & wording	8 年前
parser	Update CloudEvent implementation to adhere to the latest version (#535) * Remove Namespace attribute * Consolidate SourceID and SourceType into Source. Subscription now only expects EventType. * Use `json.RawMessage` as data type for CloudEvent. This should ensure it's properly passed down to the function manager (should not require additional processing) * CloudEvent attributes are now top level in /v1/event payload body * Update accepted content type for /v1/event to also include `application/cloudevent+json`	8 年前
transport	Dispatch single binary (#549) * Add `dispatch-server` binary, which can run most Dispatch services locally. Uses docker daemon as Function and Image backend. * Adds Entity Store-only secrets backend. * Adds in memory backend for event subscriptions. * Adds Docker backend for functions manager. * Adds flags to Image Builder to control push/pull to/from image registry. * Adds a HTTP server wrapper that handles multiple services and multiple listeners. * Added an all-in-one router that is able to route to different dispatch services using http.Handler * Fixes a bug in Event Manager where subscriptions would be recreated on update even when they don't need to. * Cleans up some of the unnecessary logging	8 年前
validator	Update CloudEvent implementation to adhere to the latest version (#535) * Remove Namespace attribute * Consolidate SourceID and SourceType into Source. Subscription now only expects EventType. * Use `json.RawMessage` as data type for CloudEvent. This should ensure it's properly passed down to the function manager (should not require additional processing) * CloudEvent attributes are now top level in /v1/event payload body * Update accepted content type for /v1/event to also include `application/cloudevent+json`	8 年前
cloudevent.go	Add exposed event driver types (#539) Event drivers may be exposed to enable push events. Driver types which are registered with the `--expose` option will create exposed drivers. These drivers will have a URL which events can be pushed to.	8 年前
doc.go	Initial transfer commit (#2)	8 年前
types.go	Make the event transport compatible with recent multi-org changes (#531) * Transport interface now expects organization for both Publish and Subscribe methods. For both Kafka and RabbitMQ, organization is prepended to the topic. This has certain implications on organization name/allowed characters. If this becomes a problem, we should consider using some other Organization ID. * RabbitMQ now uses single Exchange. Previous approach was to declare separate Exchange for each organization, but this would require event manager to listen on changes in Organization entities. For now, a simpler approach of using single exchange and prepending the org to the topic is used. * Cosmetic improvements in error handling & wording	8 年前