From 06517075bf982a145a49370a6b4086f48476e084 Mon Sep 17 00:00:00 2001 From: Jaden Weiss Date: Thu, 4 Jun 2020 14:05:06 -0400 Subject: [PATCH] add unit test to active query tracker --- tracker_test.go | 42 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 42 insertions(+) create mode 100644 tracker_test.go diff --git a/tracker_test.go b/tracker_test.go new file mode 100644 index 000000000..80f6f84f2 --- /dev/null +++ b/tracker_test.go @@ -0,0 +1,42 @@ +// Copyright 2020 Pilosa Corp. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package pilosa + +import "testing" + +func TestQueryTracker(t *testing.T) { + tracker := newQueryTracker() + defer tracker.Stop() + + if queries := tracker.ActiveQueries(); len(queries) > 0 { + t.Fatalf("expected no active queries; found %v", queries) + } + + qs := tracker.Start("test query") + + var queries []ActiveQueryStatus + for len(queries) < 1 { + queries = tracker.ActiveQueries() + } + if len(queries) > 1 || queries[0].Query != "test query" { + t.Fatalf("unexpected queries: %v", queries) + } + + tracker.Finish(qs) + + for len(queries) > 0 { + queries = tracker.ActiveQueries() + } +}