Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for runComponent (0.27 sec)

  1. pilot/pkg/server/instance_test.go

    	expected := errors.New("fake")
    	inst.RunComponent("fake", func(stop <-chan struct{}) error {
    		return expected
    	})
    
    	stop := newReclosableChannel()
    	t.Cleanup(stop.Close)
    	g.Expect(inst.Start(stop.c)).To(Equal(expected))
    }
    
    func TestStartWithNoError(t *testing.T) {
    	g := NewWithT(t)
    
    	inst := server.New()
    	c := newFakeComponent(0, test.NewStop(t))
    	inst.RunComponent("fake", c.Run)
    
    	stop := newReclosableChannel()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 23:02:39 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. pilot/pkg/bootstrap/server.go

    // so the function should start a go routine if it needs to do anything blocking
    func (s *Server) addStartFunc(name string, fn server.Component) {
    	s.server.RunComponent(name, fn)
    }
    
    // adds a readiness probe for Istiod Server.
    func (s *Server) addReadinessProbe(name string, fn readinessProbe) {
    	s.readinessProbes[name] = fn
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
Back to top