Documentation ¶
Index ¶
- type EventListener
- func (el *EventListener) GetEventName() string
- func (el *EventListener) GetEventSourceName() string
- func (el *EventListener) GetEventSourceType() v1alpha1.EventSourceType
- func (el *EventListener) StartListening(ctx context.Context, dispatch func([]byte, ...eventsourcecommon.Option) error) error
- func (listener *EventListener) ValidateEventSource(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventListener ¶
type EventListener struct { EventSourceName string EventName string MinioEventSource v1alpha1.S3Artifact Metrics *metrics.Metrics }
EventListener implements Eventing for minio event sources
func (*EventListener) GetEventName ¶
func (el *EventListener) GetEventName() string
GetEventName returns name of event
func (*EventListener) GetEventSourceName ¶
func (el *EventListener) GetEventSourceName() string
GetEventSourceName returns name of event source
func (*EventListener) GetEventSourceType ¶
func (el *EventListener) GetEventSourceType() v1alpha1.EventSourceType
GetEventSourceType return type of event server
func (*EventListener) StartListening ¶
func (el *EventListener) StartListening(ctx context.Context, dispatch func([]byte, ...eventsourcecommon.Option) error) error
StartListening starts listening events
func (*EventListener) ValidateEventSource ¶
func (listener *EventListener) ValidateEventSource(ctx context.Context) error
ValidateEventSource validates the minio event source
Click to show internal directories.
Click to hide internal directories.