kafka

Documentation

Index

• Constants
• func NewKafkaEventSource(log logr.Logger, spec *ofevent.KafkaSpec) event.OpenFunctionEventSource
• type EventSource
  • func (es *EventSource) GenComponent(namespace string, name string) (*componentsv1alpha1.Component, error)
  • func (es *EventSource) GenScaleOptions() (*ofcore.KedaScaledObject, *kedav1alpha1.ScaleTriggers)
  • func (es *EventSource) GetMetadata() map[string]interface{}
  • func (es *EventSource) SetMetadata(key string, value interface{})

Constants

const (
	ComponentType    = "bindings.kafka"
	ComponentVersion = "v1"
	ScaledObjectType = "kafka"
)

Functions

func NewKafkaEventSource

func NewKafkaEventSource(log logr.Logger, spec *ofevent.KafkaSpec) event.OpenFunctionEventSource

Types

type EventSource

type EventSource struct {
	Spec     *ofevent.KafkaSpec
	Metadata map[string]interface{}
	// contains filtered or unexported fields
}

func (*EventSource) GenComponent

func (es *EventSource) GenComponent(namespace string, name string) (*componentsv1alpha1.Component, error)

func (*EventSource) GenScaleOptions

func (es *EventSource) GenScaleOptions() (*ofcore.KedaScaledObject, *kedav1alpha1.ScaleTriggers)

func (*EventSource) GetMetadata

func (es *EventSource) GetMetadata() map[string]interface{}

func (*EventSource) SetMetadata

func (es *EventSource) SetMetadata(key string, value interface{})