Documentation
¶
Index ¶
Constants ¶
View Source
const ArgoEventsEventSourceVersion = "v0.11"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaEventSourceExecutor ¶
KafkaEventSourceExecutor implements Eventing
func (*KafkaEventSourceExecutor) StartEventSource ¶
func (ese *KafkaEventSourceExecutor) StartEventSource(eventSource *gateways.EventSource, eventStream gateways.Eventing_StartEventSourceServer) error
StartEventSource starts an event source
func (*KafkaEventSourceExecutor) ValidateEventSource ¶
func (ese *KafkaEventSourceExecutor) ValidateEventSource(ctx context.Context, es *gateways.EventSource) (*gateways.ValidEventSource, error)
ValidateEventSource validates the gateway event source
Click to show internal directories.
Click to hide internal directories.