stats_service_test.go 1.2 KB
Newer Older
1
package querynode
2

D
dragondriver 已提交
3 4 5 6
import (
	"testing"

	"github.com/zilliztech/milvus-distributed/internal/msgstream"
X
Xiangyu Wang 已提交
7
	"github.com/zilliztech/milvus-distributed/internal/msgstream/pulsarms"
D
dragondriver 已提交
8 9 10 11
)

// NOTE: start pulsar before test
func TestStatsService_start(t *testing.T) {
12
	node := newQueryNodeMock()
B
bigsheeper 已提交
13
	initTestMeta(t, node, 0, 0)
14
	node.statsService = newStatsService(node.queryNodeLoopCtx, node.replica, nil)
D
dragondriver 已提交
15
	node.statsService.start()
C
cai.zhang 已提交
16
	node.Stop()
D
dragondriver 已提交
17 18
}

X
XuanYang-cn 已提交
19
//NOTE: start pulsar before test
20
func TestSegmentManagement_sendSegmentStatistic(t *testing.T) {
21
	node := newQueryNodeMock()
B
bigsheeper 已提交
22
	initTestMeta(t, node, 0, 0)
D
dragondriver 已提交
23 24 25

	const receiveBufSize = 1024
	// start pulsar
26
	producerChannels := []string{Params.StatsChannelName}
D
dragondriver 已提交
27

28
	pulsarURL := Params.PulsarAddress
S
sunby 已提交
29 30 31 32 33

	factory := msgstream.ProtoUDFactory{}
	statsStream := pulsarms.NewPulsarMsgStream(node.queryNodeLoopCtx, receiveBufSize, 1024, factory.NewUnmarshalDispatcher())
	statsStream.SetPulsarClient(pulsarURL)
	statsStream.CreatePulsarProducers(producerChannels)
D
dragondriver 已提交
34 35 36

	var statsMsgStream msgstream.MsgStream = statsStream

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

	// send stats
42
	node.statsService.publicStatistic(nil)
C
cai.zhang 已提交
43
	node.Stop()
D
dragondriver 已提交
44
}