Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. pilot/pkg/server/instance.go

    	//
    	// Once all startup components have been run, starts a polling
    	// loop to continue monitoring for new components and returns nil.
    	Start(stop <-chan struct{}) error
    
    	// RunComponent adds the given component to the server's run queue.
    	RunComponent(name string, t Component)
    
    	// RunComponentAsync runs the given component asynchronously.
    	RunComponentAsync(name string, t Component)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  2. 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)
Back to top