Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 608 for prober (0.11 sec)

  1. pkg/kubelet/prober/prober.go

    	httpprobe "k8s.io/kubernetes/pkg/probe/http"
    	tcpprobe "k8s.io/kubernetes/pkg/probe/tcp"
    	"k8s.io/utils/exec"
    
    	"k8s.io/klog/v2"
    )
    
    const maxProbeRetries = 3
    
    // Prober helps to check the liveness/readiness/startup of a container.
    type prober struct {
    	exec   execprobe.Prober
    	http   httpprobe.Prober
    	tcp    tcpprobe.Prober
    	grpc   grpcprobe.Prober
    	runner kubecontainer.CommandRunner
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 10:50:13 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. pkg/volume/flexvolume/probe.go

    	if err := prober.createPluginDir(); err != nil {
    		return err
    	}
    	if err := prober.initWatcher(); err != nil {
    		return err
    	}
    
    	return nil
    }
    
    // If probeAllNeeded is true, probe all pluginDir
    // else probe events in eventsMap
    func (prober *flexVolumeProber) Probe() (events []volume.ProbeEvent, err error) {
    	if prober.probeAllNeeded {
    		prober.testAndSetProbeAllNeeded(false)
    		return prober.probeAll()
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 28 11:14:00 UTC 2023
    - 9K bytes
    - Viewed (0)
  3. pilot/cmd/pilot-agent/status/server.go

    	}
    	if prober.HTTPGet != nil && prober.HTTPGet.Port.Type != apimirror.Int {
    		return fmt.Errorf("invalid prober config for %v, the port must be int type", path)
    	}
    	if prober.TCPSocket != nil && prober.TCPSocket.Port.Type != apimirror.Int {
    		return fmt.Errorf("invalid prober config for %v, the port must be int type", path)
    	}
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 31.1K bytes
    - Viewed (1)
  4. pkg/volume/flexvolume/probe_test.go

    	assert.NoError(t, err)
    
    	// Should no longer probe.
    
    	// Act
    	events, err = prober.Probe()
    	// Assert
    	assert.Equal(t, 0, len(events))
    	assert.NoError(t, err)
    }
    
    // Probes newly added drivers after prober is running.
    func TestProberAddRemoveDriver(t *testing.T) {
    	// Arrange
    	_, fs, watcher, prober := initTestEnvironment(t)
    	prober.Probe()
    	events, err := prober.Probe()
    	assert.NoError(t, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 28 11:14:00 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  5. pkg/probe/exec/exec.go

    	"k8s.io/kubernetes/pkg/probe"
    
    	"k8s.io/klog/v2"
    	"k8s.io/utils/exec"
    )
    
    const (
    	maxReadLength = 10 * 1 << 10 // 10KB
    )
    
    // New creates a Prober.
    func New() Prober {
    	return execProber{}
    }
    
    // Prober is an interface defining the Probe object for container readiness/liveness checks.
    type Prober interface {
    	Probe(e exec.Cmd) (probe.Result, string, error)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  6. pkg/kubelet/prober/prober_manager_test.go

    	m.CleanupPods(desiredPods)
    
    	removedProbes := []probeKey{
    		{"pod_cleanup", "prober1", readiness},
    		{"pod_cleanup", "prober2", liveness},
    		{"pod_cleanup", "prober3", startup},
    	}
    	expectedProbes := []probeKey{
    		{"pod_keep", "prober1", readiness},
    		{"pod_keep", "prober2", liveness},
    		{"pod_keep", "prober3", startup},
    	}
    	if err := waitForWorkerExit(t, m, removedProbes); err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go

    		return newETCD3ProberMonitor(c)
    	default:
    		return nil, fmt.Errorf("unknown storage type: %s", c.Type)
    	}
    }
    
    // Prober is an interface that defines the Probe function for doing etcd readiness/liveness checks.
    type Prober interface {
    	Probe(ctx context.Context) error
    	Close() error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  8. pilot/cmd/pilot-agent/status/server_test.go

    	testCases := []struct {
    		name   string
    		probes []ready.Prober
    		err    error
    	}{
    		{
    			name:   "success probe",
    			probes: []ready.Prober{rp},
    			err:    nil,
    		},
    		{
    			name:   "not ready probe",
    			probes: []ready.Prober{urp},
    			err:    errors.New("not ready"),
    		},
    		{
    			name:   "both probes",
    			probes: []ready.Prober{rp, urp},
    			err:    errors.New("not ready"),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  9. pilot/cmd/pilot-agent/status/ready/probe.go

    	Check() error
    }
    
    var _ Prober = &Probe{}
    
    // Check executes the probe and returns an error if the probe fails.
    func (p *Probe) Check() error {
    	// First, check that Envoy has received a configuration update from Pilot.
    	if err := p.checkConfigStatus(); err != nil {
    		return err
    	}
    	return p.isEnvoyReady()
    }
    
    // checkConfigStatus checks to make sure initial configs have been received from Pilot.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 00:35:05 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  10. pkg/probe/exec/exec_test.go

    		err              error
    	}{
    		// Ok
    		{probe.Success, false, true, "OK", "OK", nil},
    		// Ok
    		{probe.Success, false, true, "OK", "OK", &fakeExitError{true, 0}},
    		// Ok - truncated output
    		{probe.Success, false, true, elevenKilobyte, tenKilobyte, nil},
    		// Run returns error
    		{probe.Unknown, true, true, "", "", fmt.Errorf("test error")},
    		// Unhealthy
    		{probe.Failure, false, true, "Fail", "", &fakeExitError{true, 1}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 3.8K bytes
    - Viewed (0)
Back to top