MCPcopy Index your code
hub / github.com/OpenFunction/OpenFunction / OpenFunctionEventSource

Interface OpenFunctionEventSource

pkg/event/event.go:26–31  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

24)
25
26type OpenFunctionEventSource interface {
27 SetMetadata(key string, value interface{})
28 GetMetadata() map[string]interface{}
29 GenComponent(namespace string, name string) (*componentsv1alpha1.Component, error)
30 GenScaleOptions() (*ofcore.KedaScaledObject, *kedav1alpha1.ScaleTriggers)
31}
32
33type OpenFunctionEventBus interface {
34 SetMetadata(key string, value interface{})

Callers

nothing calls this directly

Implementers 5

EventBuspkg/event/eventbus/natsstreaming/natss
EventSourcepkg/event/eventsource/cron/cron.go
EventSourcepkg/event/eventsource/kafka/kafka.go
EventSourcepkg/event/eventsource/redis/redis.go
EventSourcepkg/event/eventsource/mqtt/mqtt.go

Calls

no outgoing calls

Tested by

no test coverage detected