Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
doodoocoder
prometheus
提交
dc0fb2b5
P
prometheus
项目概览
doodoocoder
/
prometheus
与 Fork 源项目一致
从无法访问的项目Fork
通知
2
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
P
prometheus
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
dc0fb2b5
编写于
4月 21, 2017
作者:
F
Fabian Reinartz
提交者:
GitHub
4月 21, 2017
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #54 from prometheus/query-test
Test we get back out the data we put in.
上级
2fcdd1a5
2742fc38
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
38 addition
and
27 deletion
+38
-27
db_test.go
db_test.go
+38
-27
未找到文件。
db_test.go
浏览文件 @
dc0fb2b5
...
...
@@ -19,43 +19,59 @@ import (
"testing"
"github.com/prometheus/tsdb/labels"
"github.com/stretchr/testify/require"
)
// Convert a SeriesSet into a form useable with reflect.DeepEqual.
func
readSeriesSet
(
ss
SeriesSet
)
(
map
[
string
][]
sample
,
error
)
{
result
:=
map
[
string
][]
sample
{}
for
ss
.
Next
()
{
series
:=
ss
.
At
()
samples
:=
[]
sample
{}
it
:=
series
.
Iterator
()
for
it
.
Next
()
{
t
,
v
:=
it
.
At
()
samples
=
append
(
samples
,
sample
{
t
:
t
,
v
:
v
})
}
name
:=
series
.
Labels
()
.
String
()
result
[
name
]
=
samples
if
err
:=
ss
.
Err
();
err
!=
nil
{
return
nil
,
err
}
}
return
result
,
nil
}
func
TestDataAvailableOnlyAfterCommit
(
t
*
testing
.
T
)
{
tmpdir
,
_
:=
ioutil
.
TempDir
(
""
,
"test"
)
defer
os
.
RemoveAll
(
tmpdir
)
db
,
err
:=
Open
(
tmpdir
,
nil
,
nil
,
nil
)
if
err
!=
nil
{
t
.
Fatalf
(
"Error opening database: %q"
,
err
)
}
require
.
NoError
(
t
,
err
)
defer
db
.
Close
()
app
:=
db
.
Appender
()
_
,
err
=
app
.
Add
(
labels
.
FromStrings
(
"foo"
,
"bar"
),
0
,
0
)
if
err
!=
nil
{
t
.
Fatalf
(
"Error adding sample: %q"
,
err
)
}
require
.
NoError
(
t
,
err
)
querier
:=
db
.
Querier
(
0
,
1
)
defer
querier
.
Close
()
seriesSet
:=
querier
.
Select
(
labels
.
NewEqualMatcher
(
"foo"
,
"bar"
))
if
seriesSet
.
Next
()
{
t
.
Fatalf
(
"Error, was expecting no matching series."
)
}
seriesSet
,
err
:=
readSeriesSet
(
querier
.
Select
(
labels
.
NewEqualMatcher
(
"foo"
,
"bar"
)))
require
.
NoError
(
t
,
err
)
require
.
Equal
(
t
,
seriesSet
,
map
[
string
][]
sample
{})
err
=
app
.
Commit
()
if
err
!=
nil
{
t
.
Fatalf
(
"Error committing: %q"
,
err
)
}
require
.
NoError
(
t
,
err
)
querier
=
db
.
Querier
(
0
,
1
)
defer
querier
.
Close
()
seriesSet
=
querier
.
Select
(
labels
.
NewEqualMatcher
(
"foo"
,
"bar"
))
if
!
seriesSet
.
Next
()
{
t
.
Fatalf
(
"Error, was expecting a matching series."
)
}
seriesSet
,
err
=
readSeriesSet
(
querier
.
Select
(
labels
.
NewEqualMatcher
(
"foo"
,
"bar"
)))
require
.
NoError
(
t
,
err
)
require
.
Equal
(
t
,
seriesSet
,
map
[
string
][]
sample
{
`{foo="bar"}`
:
[]
sample
{{
t
:
0
,
v
:
0
}}})
}
func
TestDataNotAvailableAfterRollback
(
t
*
testing
.
T
)
{
...
...
@@ -70,20 +86,15 @@ func TestDataNotAvailableAfterRollback(t *testing.T) {
app
:=
db
.
Appender
()
_
,
err
=
app
.
Add
(
labels
.
FromStrings
(
"foo"
,
"bar"
),
0
,
0
)
if
err
!=
nil
{
t
.
Fatalf
(
"Error adding sample: %q"
,
err
)
}
require
.
NoError
(
t
,
err
)
err
=
app
.
Rollback
()
if
err
!=
nil
{
t
.
Fatalf
(
"Error rolling back: %q"
,
err
)
}
require
.
NoError
(
t
,
err
)
querier
:=
db
.
Querier
(
0
,
1
)
defer
querier
.
Close
()
seriesSet
:=
querier
.
Select
(
labels
.
NewEqualMatcher
(
"foo"
,
"bar"
))
if
seriesSet
.
Next
()
{
t
.
Fatalf
(
"Error, was expecting no matching series."
)
}
seriesSet
,
err
:=
readSeriesSet
(
querier
.
Select
(
labels
.
NewEqualMatcher
(
"foo"
,
"bar"
)))
require
.
NoError
(
t
,
err
)
require
.
Equal
(
t
,
seriesSet
,
map
[
string
][]
sample
{})
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录