makeID - Code Search

pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

		// an unschedulable Pod schedulable.
		// - Delete. An unschedulable Pod may fail due to violating an existing Pod's topology spread constraints,
		// deleting an existing Pod may make it schedulable.
		{Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.All}, QueueingHintFn: pl.isSchedulableAfterPodChange},
		// Node add|delete|update maybe lead an topology key changed,

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Sat Mar 16 14:13:06 UTC 2024

- 12.7K bytes

- Viewed (0)

github.com/golang/go

test/fixedbugs/issue24491a.go

// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// This test makes sure unsafe-uintptr arguments are handled correctly.

package main

import (
	"runtime"
	"unsafe"
)

var done = make(chan bool, 1)

func setup() unsafe.Pointer {
	s := "ok"
	runtime.SetFinalizer(&s, func(p *string) { *p = "FAIL" })
	return unsafe.Pointer(&s)
}

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu Aug 17 19:36:58 UTC 2023

- 1.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/config/config.go

		return false
	}
	return true
}

// checkAndUpdatePod updates existing, and:
//   - if ref makes a meaningful change, returns needUpdate=true
//   - if ref makes a meaningful change, and this change is graceful deletion, returns needGracefulDelete=true
//   - if ref makes no meaningful change, but changes the pod status, returns needReconcile=true
//   - else return all false

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Tue Jun 04 06:25:43 UTC 2024

- 16.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/scheduler/framework/plugins/volumebinding/test_utils.go

	*v1.PersistentVolume
}

func makePV(name, className string) pvBuilder {
	return pvBuilder{PersistentVolume: &v1.PersistentVolume{
		ObjectMeta: metav1.ObjectMeta{
			Name: name,
		},
		Spec: v1.PersistentVolumeSpec{
			StorageClassName: className,
		},
	}}
}

func (pvb pvBuilder) withNodeAffinity(keyValues map[string][]string) pvBuilder {
	matchExpressions := make([]v1.NodeSelectorRequirement, 0)

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Sep 13 07:42:19 UTC 2023

- 4.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/apis/core/validation/events.go

		if event.Series.LastObservedTime.Time == zeroTime {
			allErrs = append(allErrs, field.Required(field.NewPath("series.lastObservedTime"), ""))
		}
	}
	return allErrs
}

// legacyValidateEvent makes sure that the event makes sense.
func legacyValidateEvent(event *core.Event, requestVersion schema.GroupVersion) field.ErrorList {
	allErrs := field.ErrorList{}
	// Because go
	zeroTime := time.Time{}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Sep 01 19:47:37 UTC 2022

- 9.2K bytes

- Viewed (0)

github.com/istio/istio

pilot/cmd/pilot-agent/app/request.go

// which interprets the output literally as json document.
var (
	requestCmd = &cobra.Command{
		Use:   "request <method> <path> [<body>]",
		Short: "Makes an HTTP request to the Envoy admin API",
		Args:  cobra.MinimumNArgs(2),
		PreRunE: func(cmd *cobra.Command, args []string) error {
			if !allowedPorts.Contains(debugRequestPort) {

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Fri Dec 08 03:13:05 UTC 2023

- 2K bytes

- Viewed (0)

github.com/golang/go

src/cmd/internal/bootstrap_test/overlaydir_test.go

// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package bootstrap_test

import (
	"io"
	"io/fs"
	"os"
	"path/filepath"
	"strings"
)

// overlayDir makes a minimal-overhead copy of srcRoot in which new files may be added.
//
// TODO: Once we no longer need to support the misc module in GOPATH mode,
// factor this function out into a package to reduce duplication.

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri May 12 12:35:05 UTC 2023

- 2.1K bytes

- Viewed (0)

github.com/istio/istio

pkg/queue/delay.go

	var n int
	if n = runtime.GOMAXPROCS(0); n == 1 {
		return 0
	}

	// Make channel non-blocking and set up its capacity with GOMAXPROCS if GOMAXPROCS>1,
	// otherwise the sender might be dragged down if the receiver is CPU-bound.
	//
	// GOMAXPROCS determines how many goroutines can run in parallel,
	// which makes it the best choice as the channel capacity,
	return n
}()

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Thu Jul 20 06:27:31 UTC 2023

- 6.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apimachinery/pkg/types/nodename.go

//
// * The cloudproviders have the own names: GCE has InstanceName, AWS has InstanceId.
//
//	For GCE, InstanceName is the Name of an Instance object in the GCE API.  On GCE, Instance.Name becomes the
//	Hostname, and thus it makes sense also to use it as the Node.Name.  But that is GCE specific, and it is up
//	to the cloudprovider how to do this mapping.
//
//	For AWS, the InstanceID is not yet suitable for use as a Node.Name, so we actually use the

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Tue Jul 26 17:14:05 UTC 2022

- 2K bytes

- Viewed (0)

github.com/golang/go

src/sync/map_reference_test.go

func (m *RWMutexMap) Store(key, value any) {
	m.mu.Lock()
	if m.dirty == nil {
		m.dirty = make(map[any]any)
	}
	m.dirty[key] = value
	m.mu.Unlock()
}

func (m *RWMutexMap) LoadOrStore(key, value any) (actual any, loaded bool) {
	m.mu.Lock()
	actual, loaded = m.dirty[key]
	if !loaded {
		actual = value
		if m.dirty == nil {
			m.dirty = make(map[any]any)
		}
		m.dirty[key] = value
	}
	m.mu.Unlock()

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu Feb 01 15:34:22 UTC 2024

- 5.6K bytes

- Viewed (0)

Search Options