query_node_test.go

package querynode

import (
	"context"
	"testing"
	"time"
)

const ctxTimeInMillisecond = 200
const closeWithDeadline = true

// NOTE: start pulsar and etcd before test
func TestQueryNode_start(t *testing.T) {
	Params.Init()

	var ctx context.Context
	if closeWithDeadline {
		var cancel context.CancelFunc
		d := time.Now().Add(ctxTimeInMillisecond * time.Millisecond)
		ctx, cancel = context.WithDeadline(context.Background(), d)
		defer cancel()
	} else {
		ctx = context.Background()
	}

	node := NewQueryNode(ctx, 0)
	node.Start()
	node.Close()
}