INNER CODE UNIT · Go

TestApplyRoutersThenRestartReloadKeepsRouters

rulego/rulego · endpoint/deferred_reload_test.go:34

func TestApplyRoutersThenRestartReloadKeepsRouters(t *testing.T) {
	_ = Registry.Register(&deferredStubEndpoint{})

	def := types.EndpointDsl{
		RuleNode: types.RuleNode{
			Id:            "ep_deferred_reload",
			Type:          "deferredStub",
			Configuration: types.Configuration{"k": "v1"},
		},
		Routers: []*types.RouterDsl{
			{Id: "r1", From: types.FromDsl{Path: "/t"}, To: types.ToDsl{Path: "chainX"}},
		},
	}
	ep, err := NewPool().Factory().NewFromDef(def, endpointApi.DynamicEndpointOptions.WithDeferredRouters(true))
	assert.Nil(t, err)

	assert.Nil(t, ep.ApplyRouters())
	before := atomic.LoadInt64(&deferredStubAddRouterCount)

View source record →