Function TestRegistry_Deregister

contrib/registry/polaris/polaris_z_test.go:55–84

TestRegistry_Deregister TestRegistryManyService

(t *testing.T)

// TestRegistry_Deregister TestRegistryManyService
func TestRegistry_Deregister(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/backup")
	if err := api.SetLoggersDir(os.TempDir() + "/polaris-registry/log"); err != nil {
		t.Fatal(err)
	}

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

	svc := &gsvc.LocalService{
		Name:      "goframe-provider-deregister-tcp",
		Version:   "test",
		Metadata:  map[string]any{"app": "goframe", gsvc.MDProtocol: "tcp"},
		Endpoints: gsvc.NewEndpoints("127.0.0.1:9000"),
	}

	s, err := r.Register(context.Background(), svc)
	if err != nil {
		t.Fatal(err)
	}

	if err = r.Deregister(context.Background(), s); err != nil {
		t.Fatal(err)
	}
}

// TestRegistryMany TestRegistryManyService
func TestRegistryMany(t *testing.T) {