Documentation ¶
Index ¶
- Constants
- func NewNatsStreamingEventBus(log logr.Logger, spec *ofevent.NatsStreamingSpec) event.OpenFunctionEventBus
- type EventBus
- func (eb *EventBus) GenComponent(namespace string, name string) (*componentsv1alpha1.Component, error)
- func (eb *EventBus) GenScaleOptions(subjects []string) (*ofcore.KedaScaledObject, []*kedav1alpha1.ScaleTriggers)
- func (eb *EventBus) GetMetadata() map[string]interface{}
- func (eb *EventBus) SetMetadata(key string, value interface{})
Constants ¶
View Source
const ( ComponentType = "pubsub.natsstreaming" ComponentVersion = "v1" ScaledObjectType = "stan" )
Variables ¶
This section is empty.
Functions ¶
func NewNatsStreamingEventBus ¶
func NewNatsStreamingEventBus(log logr.Logger, spec *ofevent.NatsStreamingSpec) event.OpenFunctionEventBus
Types ¶
type EventBus ¶
type EventBus struct { Spec *ofevent.NatsStreamingSpec Metadata map[string]interface{} // contains filtered or unexported fields }
func (*EventBus) GenComponent ¶
func (*EventBus) GenScaleOptions ¶
func (eb *EventBus) GenScaleOptions(subjects []string) (*ofcore.KedaScaledObject, []*kedav1alpha1.ScaleTriggers)
func (*EventBus) GetMetadata ¶
func (*EventBus) SetMetadata ¶
Click to show internal directories.
Click to hide internal directories.