体验新版 GitCode,发现更多精彩内容 >>
package reader import ( "context"
"github.com/zilliztech/milvus-distributed/internal/conf"
"strconv" "testing" "time" ) const ctxTimeInMillisecond = 10 // NOTE: start pulsar before test func TestReader_startQueryNode(t *testing.T) { conf.LoadConfig("config.yaml") d := time.Now().Add(ctxTimeInMillisecond * time.Millisecond) ctx, _ := context.WithDeadline(context.Background(), d) pulsarAddr := "pulsar://" pulsarAddr += conf.Config.Pulsar.Address pulsarAddr += ":" pulsarAddr += strconv.FormatInt(int64(conf.Config.Pulsar.Port), 10) StartQueryNode(ctx, pulsarAddr) }