- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 165 for makeID (0.25 sec)
-
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go
return nil } gates := make([]string, 0, len(p.Spec.SchedulingGates)) for _, gate := range p.Spec.SchedulingGates { gates = append(gates, gate.Name) } return framework.NewStatus(framework.UnschedulableAndUnresolvable, fmt.Sprintf("waiting for scheduling gates: %v", gates)) } // EventsToRegister returns the possible events that may make a Pod // failed by this plugin schedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go
// So, it's enough to just check the length of tolerations to notice the update. // And, any updates in tolerations could make Pod schedulable. logger.V(5).Info("a new toleration is added for the Pod, and it may make it schedulable", "pod", klog.KObj(modifiedPod)) return framework.Queue, nil } return framework.QueueSkip, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 9.2K bytes - Viewed (0) -
src/time/tick_test.go
} tim.Stop() drainAsync() noTick() // Again using select and with two goroutines waiting. tim.Reset(10000 * Second) drainAsync() done = make(chan bool, 2) done1 := make(chan bool) done2 := make(chan bool) stop := make(chan bool) go func() { select { case <-C: done <- true case <-stop: } close(done1) }() go func() { select { case <-C:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
return nil } // makeEmptyQueueingHintMapPerProfile initializes an empty QueueingHintMapPerProfile for "" profile name. func makeEmptyQueueingHintMapPerProfile() QueueingHintMapPerProfile { m := make(QueueingHintMapPerProfile) m[""] = make(QueueingHintMap) return m } func TestPriorityQueue_Add(t *testing.T) { objs := []runtime.Object{medPriorityPodInfo.Pod, unschedulablePodInfo.Pod, highPriorityPodInfo.Pod}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
} } l.FilterChains = append(l.FilterChains, chains...) } // If there are no filter chains, populate a dummy one that never matches. Envoy doesn't allow no chains, but removing the // entire listeners makes the errors logs more confusing (instead of "no filter chain found" we have no listener at all). if len(l.FilterChains) == 0 { l.FilterChains = []*listener.FilterChain{{ Name: model.VirtualInboundBlackholeFilterChainName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
cmd/erasure-healing-common.go
availableDisks = make([]StorageAPI, len(onlineDisks)) dataErrsByDisk = make(map[int][]int, len(onlineDisks)) for i := range onlineDisks { dataErrsByDisk[i] = make([]int, len(latestMeta.Parts)) } dataErrsByPart = make(map[int][]int, len(latestMeta.Parts)) for i := range latestMeta.Parts { dataErrsByPart[i] = make([]int, len(onlineDisks)) } inconsistent := 0
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 12.5K bytes - Viewed (0) -
callbacks/preload.go
inlineConds []interface{} ) if rel.JoinTable != nil { var ( joinForeignFields = make([]*schema.Field, 0, len(rel.References)) joinRelForeignFields = make([]*schema.Field, 0, len(rel.References)) joinForeignKeys = make([]string, 0, len(rel.References)) ) for _, ref := range rel.References { if ref.OwnPrimaryKey {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:52:33 UTC 2024 - 11.6K bytes - Viewed (0) -
callbacks/query.go
clauseSelect.Columns = make([]clause.Column, len(db.Statement.Schema.DBNames)) for idx, dbName := range db.Statement.Schema.DBNames { clauseSelect.Columns[idx] = clause.Column{Table: db.Statement.Table, Name: dbName} } } specifiedRelationsName := make(map[string]interface{}) for _, join := range db.Statement.Joins {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 09:51:44 UTC 2024 - 10.1K bytes - Viewed (0) -
api/maven-api-plugin/src/main/mdo/plugin.mdo
<version>1.1.0</version> <type>boolean</type> <description>Marks this Mojo as using Maven 4 API. This makes the plugin implicitly incompatible with earlier Maven versions. Only evaluated since Maven 4.</description> <defaultValue>false</defaultValue> </field> <field> <name>instantiationStrategy</name> <version>1.0.0/1.1.0</version>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 24.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
// depending on context. Object runtime.Object } type emptyWatch chan Event // NewEmptyWatch returns a watch interface that returns no results and is closed. // May be used in certain error conditions where no information is available but // an error is not warranted. func NewEmptyWatch() Interface { ch := make(chan Event) close(ch) return emptyWatch(ch) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1)