eventsources

Documentation

Index

• func GetEventingServers(eventSource *v1alpha1.EventSource, metrics *eventsourcemetrics.Metrics) map[apicommon.EventSourceType][]EventingServer
• type EventSourceAdaptor
  • func NewEventSourceAdaptor(eventSource *v1alpha1.EventSource, eventBusConfig *eventbusv1alpha1.BusConfig, ...) *EventSourceAdaptor
  • func (e *EventSourceAdaptor) Start(ctx context.Context) error
• type EventingServer

Functions

func GetEventingServers

func GetEventingServers(eventSource *v1alpha1.EventSource, metrics *eventsourcemetrics.Metrics) map[apicommon.EventSourceType][]EventingServer

GetEventingServers returns the mapping of event source type and list of eventing servers

Types

type EventSourceAdaptor

type EventSourceAdaptor struct {
	// contains filtered or unexported fields
}

EventSourceAdaptor is the adaptor for eventsource service

func NewEventSourceAdaptor

func NewEventSourceAdaptor(eventSource *v1alpha1.EventSource, eventBusConfig *eventbusv1alpha1.BusConfig, eventBusSubject, hostname string, metrics *eventsourcemetrics.Metrics) *EventSourceAdaptor

NewEventSourceAdaptor returns a new EventSourceAdaptor

func (*EventSourceAdaptor) Start

func (e *EventSourceAdaptor) Start(ctx context.Context) error

Start function

type EventingServer

type EventingServer interface {

	// ValidateEventSource validates an event source.
	ValidateEventSource(context.Context) error

	GetEventSourceName() string

	GetEventName() string

	GetEventSourceType() apicommon.EventSourceType

	// Function to start listening events.
	StartListening(ctx context.Context, dispatch func([]byte) error) error
}

EventingServer is the server API for Eventing service.