Back to

Package eventsources

Latest Go to latest

The highest tagged major version is .

Published: Sep 4, 2020 | License: Apache-2.0 | Module:


func GetEventingServers

func GetEventingServers(eventSource *v1alpha1.EventSource) map[apicommon.EventSourceType][]EventingServer

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

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.

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier