Function TestStartAcquisitionTail

pkg/acquisition/acquisition_test.go:431–462

(t *testing.T)

}

func TestStartAcquisitionTail(t *testing.T) {
	ctx := t.Context()
	sources := []types.DataSource{
		&MockTail{},
	}
	out := make(chan pipeline.Event)
	acquisTomb := tomb.Tomb{}

	go func() {
		if err := StartAcquisition(ctx, sources, out, &acquisTomb); err != nil {
			t.Error("unexpected error")
		}
	}()

	count := 0

READLOOP:
	for {
		select {
		case <-out:
			count++
		case <-time.After(1 * time.Second):
			break READLOOP
		}
	}

	assert.Equal(t, 10, count)

	acquisTomb.Kill(nil)
	time.Sleep(1 * time.Second)
	require.NoError(t, acquisTomb.Err(), "tomb is not dead")
}

type MockTailError struct {
	MockTail