Function TestRegistryManyForEndpoints

contrib/registry/polaris/polaris_z_test.go:427–525

TestRegistryManyForEndpoints TestRegistryManyForEndpointsService

(t *testing.T)

// TestRegistryManyForEndpoints TestRegistryManyForEndpointsService
func TestRegistryManyForEndpoints(t *testing.T) {
	conf := config.NewDefaultConfiguration([]string{"127.0.0.1:8091"})
	conf.GetGlobal().GetStatReporter().SetEnable(false)
	conf.Consumer.LocalCache.SetPersistDir(os.TempDir() + "/polaris-registry-many/backup")
	if err := api.SetLoggersDir(os.TempDir() + "/polaris-registry-many/log"); err != nil {
		t.Fatal(err)
	}

	r := NewWithConfig(
		conf,
		WithTimeout(time.Second*10),
		WithTTL(100),
	)

	var (
		serviceName   = "goframe-provider-tcp"
		version       = "latest"
		endpointOne   = "127.0.0.1:9000"
		endpointTwo   = "127.0.0.1:9001"
		endpointThree = "127.0.0.1:9002"
	)

	svc := &gsvc.LocalService{
		Name:      serviceName,
		Version:   version,
		Metadata:  map[string]any{"app": "goframe", gsvc.MDProtocol: "tcp"},
		Endpoints: gsvc.NewEndpoints(endpointOne),
	}

	svc1 := &gsvc.LocalService{
		Name:      serviceName,
		Version:   version,
		Metadata:  map[string]any{"app": "goframe", gsvc.MDProtocol: "tcp"},
		Endpoints: gsvc.NewEndpoints(endpointTwo),
	}

	svc2 := &gsvc.LocalService{
		Name:      serviceName,
		Version:   version,
		Metadata:  map[string]any{"app": "goframe", gsvc.MDProtocol: "tcp"},
		Endpoints: gsvc.NewEndpoints(endpointThree),
	}

	// svc register, AddEvent
	s0, err := r.Register(context.Background(), svc)
	if err != nil {
		t.Fatal(err)
	}

	// svc register, AddEvent
	s1, err := r.Register(context.Background(), svc1)
	if err != nil {
		t.Fatal(err)
	}

	// svc register, AddEvent
	s2, err := r.Register(context.Background(), svc2)
	if err != nil {