2021-01-15 06:38:36 +00:00
|
|
|
package proxynode
|
2020-11-21 11:12:59 +00:00
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"testing"
|
|
|
|
)
|
|
|
|
|
|
|
|
func TestParamTable_InsertChannelRange(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.InsertChannelNames
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_DeleteChannelNames(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.DeleteChannelNames
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_K2SChannelNames(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.K2SChannelNames
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_SearchChannelNames(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.SearchChannelNames
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_SearchResultChannelNames(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.SearchResultChannelNames
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_ProxySubName(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.ProxySubName
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_ProxyTimeTickChannelNames(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.ProxyTimeTickChannelNames
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_DataDefinitionChannelNames(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.DataDefinitionChannelNames
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_MsgStreamInsertBufSize(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.MsgStreamInsertBufSize
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_MsgStreamSearchBufSize(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.MsgStreamSearchBufSize
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_MsgStreamSearchResultBufSize(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.MsgStreamSearchResultBufSize
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_MsgStreamSearchResultPulsarBufSize(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.MsgStreamSearchResultPulsarBufSize
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestParamTable_MsgStreamTimeTickBufSize(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.MsgStreamTimeTickBufSize
|
2020-11-21 11:12:59 +00:00
|
|
|
fmt.Println(ret)
|
|
|
|
}
|
2020-11-26 08:01:31 +00:00
|
|
|
|
|
|
|
func TestParamTable_defaultPartitionTag(t *testing.T) {
|
2021-01-28 12:51:44 +00:00
|
|
|
ret := Params.DefaultPartitionTag
|
2020-11-26 08:01:31 +00:00
|
|
|
fmt.Println("default partition tag: ", ret)
|
|
|
|
}
|