Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetEventingServers ¶
func GetEventingServers(eventSource *aev1.EventSource, metrics *eventsourcemetrics.Metrics) (map[aev1.EventSourceType][]EventingServer, map[string]*aev1.EventSourceFilter)
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 *aev1.EventSource, eventBusConfig *aev1.BusConfig, eventBusSubject, hostname string, metrics *eventsourcemetrics.Metrics) *EventSourceAdaptor
NewEventSourceAdaptor returns a new EventSourceAdaptor
type EventingServer ¶
type EventingServer interface {
// ValidateEventSource validates an event source.
ValidateEventSource(context.Context) error
GetEventSourceName() string
GetEventName() string
GetEventSourceType() aev1.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.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.