for {
			select {
			case event := <-fsWatcher.Events:
				//TODO: Handle errors by taking corrective measures
				if event.Has(fsnotify.Create) {
					err := w.handleCreateEvent(event)
					if err != nil {
						klog.ErrorS(err, "Error when handling create event", "event", event)
					}
				} else if event.Has(fsnotify.Remove) {
					w.handleDeleteEvent(event)
				}
				continue

	for _, f := range c.GetWorkloadHandlers() {
		f(w, event)
	}
}

// Event represents a registry update event
type Event int

const (
	// EventAdd is sent when an object is added
	EventAdd Event = iota

	// EventUpdate is sent when an object is modified
	// Captures the modified object
	EventUpdate

	// EventDelete is sent when an object is deleted

	dataCase1 := []byte(`
<QueueConfiguration>
   <Id>1</Id>
   <Filter></Filter>
   <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue>
   <Event>s3:ObjectAccessed:*</Event>
   <Event>s3:ObjectCreated:*</Event>
   <Event>s3:ObjectRemoved:*</Event>
</QueueConfiguration>`)

	dataCase2 := []byte(`
<QueueConfiguration>
   <Id>1</Id>
    <Filter>
        <S3Key>
            <FilterRule>

    }

    @Override
    public void projectSkipped(ExecutionEvent event) {
        dispatcher.onEvent(event);
        delegate.projectSkipped(event);
    }

    @Override
    public void projectStarted(ExecutionEvent event) {
        dispatcher.onEvent(event);
        delegate.projectStarted(event);
    }

    @Override
    public void projectSucceeded(ExecutionEvent event) {
        dispatcher.onEvent(event);

            assertTrue event.eventTime == 999
            assertTrue event.displayName == "Project configuration started"
            assertTrue event.descriptor.displayName == 'Project configuration'
            assertTrue event.descriptor.project.buildIdentifier.rootDir == rootDir
            assertTrue event.descriptor.project.projectPath == ":some:project"
        }
    }

            assertTrue event.eventTime == 999
            assertTrue event.displayName == "task started"
            assertTrue event.descriptor.name == 'some task'
            assertTrue event.descriptor.displayName == 'some task in human readable form'
            assertTrue event.descriptor.taskPath == ':some:path'
            assertTrue event.descriptor.parent == null
        }
    }

	testCases := []struct {
		desc          string
		event         *auditinternal.Event
		wantDropped   bool
		wantTruncated bool
	}{
		{
			desc:  "Empty event should not be truncated",
			event: &auditinternal.Event{},
		},
		{
			desc: "Event with too large body should be truncated",
			event: &auditinternal.Event{
				Level: auditinternal.LevelRequest,
				RequestObject: &runtime.Unknown{

            assert event.eventTime == 999
            assert event.displayName == 'build succeeded'
            assert event.descriptor.name == 'some build'
            assert event.descriptor.parent == null
            assert event.result instanceof DefaultOperationSuccessResult
            assert event.result.startTime == 1
            assert event.result.endTime == 2
        }
    }

			}
		} else {
			// event namespace must match
			if event.Namespace != event.InvolvedObject.Namespace {
				allErrs = append(allErrs, field.Invalid(field.NewPath("involvedObject", "namespace"), event.InvolvedObject.Namespace, "does not match event.namespace"))
			}
		}

	} else {

	b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack)
	b0.Event("ProcStart", trace.ProcID(1), testgen.Seq(1))
	b0.Event("GoSyscallEndBlocked")

	// A running goroutine steals proc 0.
	b1 := g.Batch(trace.ThreadID(1), 0)
	b1.Event("ProcStatus", trace.ProcID(2), go122.ProcRunning)
	b1.Event("GoStatus", trace.GoID(2), trace.ThreadID(1), go122.GoRunning)