eventsources

package
v1.1.0-rc1 Latest Latest
Warning

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

Go to latest
Published: Nov 5, 2020 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetEventingServers

func GetEventingServers(eventSource *v1alpha1.EventSource) 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) *EventSourceAdaptor

NewEventSourceAdaptor returns a new EventSourceAdaptor

func (*EventSourceAdaptor) Start

func (e *EventSourceAdaptor) Start(ctx context.Context, stopCh <-chan struct{}) 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.

Jump to

Keyboard shortcuts

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