- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 68 for pubs (0.05 sec)
-
cmd/kubeadm/app/util/version.go
var bucketURL, urlSuffix string subs := kubeBucketPrefixes.FindAllStringSubmatch(version, 1) if len(subs) != 1 || len(subs[0]) != 4 { return "", "", errors.Errorf("invalid version %q", version) } switch { case strings.HasPrefix(subs[0][2], "ci"): // Just use whichever the user specified urlSuffix = subs[0][2] bucketURL = kubeCIBucketURL default: urlSuffix = "release"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 10:50:19 UTC 2024 - 9.5K bytes - Viewed (0) -
pilot/pkg/xds/workload.go
addresses = updatedAddresses.IntersectInPlace(subs) } } if !w.Wildcard { // We only need this for on-demand. This allows us to subscribe the client to resources they // didn't explicitly request. // For wildcard, they subscribe to everything already. additional := e.Server.Env.ServiceDiscovery.AdditionalPodSubscriptions(proxy, addresses, subs) if addresses == nil { addresses = sets.New[string]() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 14:14:30 UTC 2024 - 8.7K bytes - Viewed (0) -
src/cmd/vendor/github.com/ianlancetaylor/demangle/demangle.go
if q, ok := s.(*Qualified); ok { a := q.Scope if t, ok := a.(*Template); ok { st.subs.add(t.Name) st.subs.add(t) } else { st.subs.add(a) } return s } } n := st.sourceName() if len(st.str) > 0 && st.str[0] == 'I' { st.subs.add(n) args := st.templateArgs() n = &Template{Name: n, Args: args} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 94.1K bytes - Viewed (0) -
src/runtime/tracebuf.go
w = w.refill(traceNoExperiment) } return w, refill } // flush puts w.traceBuf on the queue of full buffers. func (w traceWriter) flush() traceWriter { systemstack(func() { lock(&trace.lock) if w.traceBuf != nil { traceBufFlush(w.traceBuf, w.gen) } unlock(&trace.lock) }) w.traceBuf = nil return w } // refill puts w.traceBuf on the queue of full buffers and refresh's w's buffer. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
// for "pod" to be scheduled. // Note that both `state` and `nodeInfo` are deep copied. SelectVictimsOnNode(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo, pdbs []*policy.PodDisruptionBudget) ([]*v1.Pod, int, *framework.Status) // OrderedScoreFuncs returns a list of ordered score functions to select preferable node where victims will be preempted.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
// PodDisruptionBudgets are found. We don't return that as an error to the // caller. pdbs, err := dc.pdbLister.GetPodPodDisruptionBudgets(pod) if err != nil { logger.V(4).Info("No PodDisruptionBudgets found for pod, PodDisruptionBudget controller will avoid syncing.", "pod", klog.KObj(pod)) return nil } if len(pdbs) > 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
src/cmd/cgo/doc.go
this symbol. In the <remote>, # or @ can be used to introduce a symbol version. Examples: //go:cgo_import_dynamic puts //go:cgo_import_dynamic puts puts#GLIBC_2.2.5 //go:cgo_import_dynamic puts puts#GLIBC_2.2.5 "libc.so.6" A side effect of the cgo_import_dynamic directive with a library is to make the final binary depend on that dynamic
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 17:12:16 UTC 2024 - 42.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/ScriptDependencyResolveIntegrationTest.groovy
import org.gradle.test.fixtures.file.LeaksFileHandles import spock.lang.Issue class ScriptDependencyResolveIntegrationTest extends AbstractDependencyResolutionTest { @LeaksFileHandles("Puts gradle user home in integration test dir") @ToBeFixedForConfigurationCache(because = "task uses Configuration API") def "root component identifier has the correct type when resolving a script classpath"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 11:33:46 UTC 2024 - 6.3K bytes - Viewed (0) -
samples/bookinfo/src/details/details.rb
# See the License for the specific language governing permissions and # limitations under the License. require 'webrick' require 'json' require 'net/http' if ARGV.length < 1 then puts "usage: #{$PROGRAM_NAME} port" exit(-1) end port = Integer(ARGV[0]) server = WEBrick::HTTPServer.new( :BindAddress => '*', :Port => port,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:35:54 UTC 2024 - 5.8K bytes - Viewed (0) -
Makefile.core.mk
$(TARGET_OUT): @mkdir -p $@ # If the hub is not explicitly set, use default to istio. HUB ?=istio ifeq ($(HUB),) $(error "HUB cannot be empty") endif # For dockerx builds, allow HUBS which is a space separated list of hubs. Default to HUB. HUBS ?= $(HUB) # If tag not explicitly set in users' .istiorc.mk or command line, default to the git sha. TAG ?= $(shell git rev-parse --verify HEAD) ifeq ($(TAG),)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Jun 02 19:53:04 UTC 2024 - 23.2K bytes - Viewed (0)