Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for runComponent (0.26 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)
  3. operator/pkg/component/component.go

    		&IstioComponentBase{
    			&CommonComponentFields{
    				Options:       opts,
    				ComponentName: name.ZtunnelComponentName,
    			},
    		},
    	}
    }
    
    // runComponent performs startup tasks for the component defined by the given CommonComponentFields.
    func runComponent(c *CommonComponentFields) error {
    	r := createHelmRenderer(c)
    	if err := r.Run(); err != nil {
    		return err
    	}
    	c.renderer = r
    	c.started = true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Aug 10 15:35:03 UTC 2023
    - 11.7K bytes
    - Viewed (0)
  4. 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