Function TestUpdateExpiredEvent

tools/record/event_test.go:441–475

(t *testing.T)

}

func TestUpdateExpiredEvent(t *testing.T) {
	clock := clock.IntervalClock{Time: time.Now(), Duration: time.Second}
	eventCorrelator := NewEventCorrelator(&clock)
	randGen := rand.New(rand.NewSource(time.Now().UnixNano()))

	var createdEvent *v1.Event

	sink := &testEventSink{
		OnPatch: func(*v1.Event, []byte) (*v1.Event, error) {
			return nil, &errors.StatusError{
				ErrStatus: metav1.Status{
					Code:   http.StatusNotFound,
					Reason: metav1.StatusReasonNotFound,
				}}
		},
		OnCreate: func(event *v1.Event) (*v1.Event, error) {
			createdEvent = event
			return event, nil
		},
	}

	ev := &v1.Event{}
	ev.ResourceVersion = "updated-resource-version"
	ev.Count = 2
	recordToSink(sink, ev, eventCorrelator, randGen, 0)

	if createdEvent == nil {
		t.Error("Event did not get created after patch failed")
		return
	}

	if createdEvent.ResourceVersion != "" {
		t.Errorf("Event did not have its resource version cleared, was %s", createdEvent.ResourceVersion)
	}
}

func TestLotsOfEvents(t *testing.T) {
	recorderCalled := make(chan struct{})