Documentation
¶
Index ¶
Constants ¶
View Source
const ArgoEventsEventSourceVersion = "v0.10"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type S3EventSourceExecutor ¶
type S3EventSourceExecutor struct {
Log *logrus.Logger
// Clientset is kubernetes client
Clientset kubernetes.Interface
// Namespace where gateway is deployed
Namespace string
}
S3EventSourceExecutor implements Eventing
func (*S3EventSourceExecutor) StartEventSource ¶
func (ese *S3EventSourceExecutor) StartEventSource(eventSource *gateways.EventSource, eventStream gateways.Eventing_StartEventSourceServer) error
StartEventSource activates an event source and streams back events
func (*S3EventSourceExecutor) ValidateEventSource ¶
func (ese *S3EventSourceExecutor) ValidateEventSource(ctx context.Context, eventSource *gateways.EventSource) (*gateways.ValidEventSource, error)
ValidateEventSource validates a s3 event source
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.