stats_service_test.go 1.1 KB
Newer Older
N
neza2017 已提交
1
package querynode
2

D
dragondriver 已提交
3 4 5 6 7 8 9 10
import (
	"testing"

	"github.com/zilliztech/milvus-distributed/internal/msgstream"
)

// NOTE: start pulsar before test
func TestStatsService_start(t *testing.T) {
X
XuanYang-cn 已提交
11 12 13
	node := newQueryNode()
	initTestMeta(t, node, "collection0", 0, 0)
	node.statsService = newStatsService(node.queryNodeLoopCtx, node.replica)
D
dragondriver 已提交
14
	node.statsService.start()
X
XuanYang-cn 已提交
15
	node.Close()
D
dragondriver 已提交
16 17
}

X
XuanYang-cn 已提交
18
//NOTE: start pulsar before test
D
dragondriver 已提交
19
func TestSegmentManagement_SegmentStatisticService(t *testing.T) {
X
XuanYang-cn 已提交
20 21
	node := newQueryNode()
	initTestMeta(t, node, "collection0", 0, 0)
D
dragondriver 已提交
22 23 24

	const receiveBufSize = 1024
	// start pulsar
N
neza2017 已提交
25
	producerChannels := []string{Params.statsChannelName()}
D
dragondriver 已提交
26

X
XuanYang-cn 已提交
27 28 29
	pulsarURL, _ := Params.pulsarAddress()

	statsStream := msgstream.NewPulsarMsgStream(node.queryNodeLoopCtx, receiveBufSize)
N
neza2017 已提交
30
	statsStream.SetPulsarClient(pulsarURL)
D
dragondriver 已提交
31 32 33 34
	statsStream.CreatePulsarProducers(producerChannels)

	var statsMsgStream msgstream.MsgStream = statsStream

X
XuanYang-cn 已提交
35 36 37
	node.statsService = newStatsService(node.queryNodeLoopCtx, node.replica)
	node.statsService.statsStream = statsMsgStream
	node.statsService.statsStream.Start()
D
dragondriver 已提交
38 39 40

	// send stats
	node.statsService.sendSegmentStatistic()
X
XuanYang-cn 已提交
41
	node.Close()
D
dragondriver 已提交
42
}