Function TestMatch

pkg/systemlogmonitor/log_buffer_test.go:64–110

(t *testing.T)

}

func TestMatch(t *testing.T) {
	max := 4
	for c, test := range []struct {
		logs     []string
		exprs    []string
		expected [][]string
	}{
		{
			// Buffer not full
			logs: []string{"a1", "b2"},
			exprs: []string{
				"a1",     // Not including the last line, should not match
				"b1",     // Not match
				"b2",     // match
				`\w{2}`,  // Regexp should work
				"a1\nb2", // Including the last line, should match
				`a1b2`,   // No new line, should not match
			},
			expected: [][]string{{}, {}, {"b2"}, {"b2"}, {"a1", "b2"}, {}},
		},
		{
			// Buffer full
			logs: []string{"a1", "b2", "c3", "d4", "e5"},
			exprs: []string{
				"(?s)a1.+",         // Rotate out, should not match
				`[a-z]\d\n[a-z]\d`, // New line should work, and only the one contains the last line should match
				`[a-z]\d`,          // Multiple match, only the one contains the last line should match
			},
			expected: [][]string{{}, {"d4", "e5"}, {"e5"}},
		},
	} {
		b := NewLogBuffer(max)
		for _, log := range test.logs {
			b.Push(&types.Log{Message: log})
		}
		for i, expr := range test.exprs {
			logs := b.Match(expr)
			got := []string{}
			for _, log := range logs {
				got = append(got, log.Message)
			}
			if !reflect.DeepEqual(test.expected[i], got) {
				t.Errorf("case %d.%d: expected %v, got %v", c+1, i+1, test.expected[i], got)
			}
		}
	}
}