Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrClosedQueue = errors.New("queue is closed")
Functions ¶
This section is empty.
Types ¶
type EventHandler ¶
type EventHandler struct { Opts Options Queue chan fsnotify.Event Finished bool // contains filtered or unexported fields }
EventHandler represents the datastructure for an EventHandler instance. This struct satisfies the EventHandler interface.
func NewEventHandler ¶
func NewEventHandler(opts Options) *EventHandler
func (*EventHandler) Listen ¶
func (h *EventHandler) Listen(ctx context.Context, control PodControl)
Listen spawns workers and listens to the queue It's a blocking function and waits for a cancellation invocation from the Client.
func (*EventHandler) Push ¶
func (h *EventHandler) Push(event fsnotify.Event)
Push adds a new event payload to the queue.
Click to show internal directories.
Click to hide internal directories.