eventsources

package
v1.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2024 License: Apache-2.0 Imports: 53 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetEventingServers

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, ...eventsourcecommon.Option) error) error
}

EventingServer is the server API for Eventing service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL