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

Interface OpenFunctionEventBus

pkg/event/event.go:33–38  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

31}
32
33type OpenFunctionEventBus interface {
34 SetMetadata(key string, value interface{})
35 GetMetadata() map[string]interface{}
36 GenComponent(namespace string, name string) (*componentsv1alpha1.Component, error)
37 GenScaleOptions(subjects []string) (*ofcore.KedaScaledObject, []*kedav1alpha1.ScaleTriggers)
38}

Callers 8

handleEventBusMethod · 0.65
handleEventSourceMethod · 0.65
handleEventBusMethod · 0.65
handleEventBusMethod · 0.65
handleEventSourceMethod · 0.65
handleEventBusMethod · 0.65
handleEventSourceMethod · 0.65
handleEventBusMethod · 0.65

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