- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 165 for makeID (0.13 sec)
-
pilot/pkg/networking/core/cluster.go
// Holds clusters per service, keyed by hostname. serviceClusters := make(map[string]sets.String) // Holds service ports, keyed by hostname.Inner map port and its cluster name. // This is mainly used when service is updated and a port has been removed. servicePortClusters := make(map[string]map[int]string) // Holds subset clusters per service, keyed by hostname. subsetClusters := make(map[string]sets.String)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/model/gateway.go
mergedServers := make(map[ServerPort]*MergedServers) mergedQUICServers := make(map[ServerPort]*MergedServers) serverPorts := make([]ServerPort, 0) plainTextServers := make(map[uint32]ServerPort) serversByRouteName := make(map[string][]*networking.Server) tlsServerInfo := make(map[*networking.Server]*TLSServerInfo) gatewayNameForServer := make(map[*networking.Server]string)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0) -
pkg/kubelet/cm/qos_container_manager_linux.go
} } return nil } func (m *qosContainerManagerImpl) setCPUCgroupConfig(configs map[v1.PodQOSClass]*CgroupConfig) error { pods := m.activePods() burstablePodCPURequest := int64(0) reuseReqs := make(v1.ResourceList, 4) for i := range pods { pod := pods[i] qosClass := v1qos.GetPodQOS(pod) if qosClass != v1.PodQOSBurstable { // we only care about the burstable qos tier continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/bucket-handlers.go
postPolicyBucketTagging = "tagging" ) // Check if there are buckets on server without corresponding entry in etcd backend and // make entries. Here is the general flow // - Range over all the available buckets // - Check if a bucket has an entry in etcd backend // -- If no, make an entry // -- If yes, check if the entry matches local IP check if we // // need to update the entry then proceed to update //
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
pkg/security/security.go
ProvCert string // ClusterID is the cluster where the agent resides. // Normally initialized from ISTIO_META_CLUSTER_ID - after a tortuous journey it // makes its way into the ClusterID metadata of Citadel gRPC request to create the cert. // Didn't find much doc - but I suspect used for 'central cluster' use cases - so should // match the cluster name set in the MC setup.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 19.1K bytes - Viewed (0) -
internal/grid/handlers.go
subStateless map[subHandlerID]*StatelessHandler subStreams map[subHandlerID]*StreamHandler } func (h *handlers) init() { h.subSingle = make(map[subHandlerID]SingleHandlerFn) h.subStateless = make(map[subHandlerID]*StatelessHandler) h.subStreams = make(map[subHandlerID]*StreamHandler) } func (h *handlers) hasAny(id HandlerID) bool { if !id.valid() { return false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
platforms/jvm/testing-junit-platform/build.gradle.kts
This project should only be used by :testing-jvm-infrastructure, however it is not depended upon directly. Instead :testing-jvm-infrastructure loads classes from this project via reflection due to the above noted Java version issue. We make sure to include this subproject as a runtime dependency in :distributions-core to ensure we include it with the Gradle distribution. """ dependencies { api(projects.stdlibJavaExtensions)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 986 bytes - Viewed (0) -
pilot/pkg/bootstrap/server_test.go
p.ShutdownDuration = 1 * time.Millisecond }) g := NewWithT(t) s, err := NewServer(args, func(s *Server) { s.kubeClient = kube.NewFakeClient() }) g.Expect(err).To(Succeed()) stop := make(chan struct{}) g.Expect(s.Start(stop)).To(Succeed()) defer func() { close(stop) s.WaitUntilCompletion() }() if c.expNewCert {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 23.1K bytes - Viewed (0) -
cmd/handler-utils.go
if contentEncoding != "" { // Make sure to trim and save the content-encoding // parameter for a streaming signature which is set // to a custom value for example: "aws-chunked,gzip". metadata[strings.ToLower(xhttp.ContentEncoding)] = contentEncoding } else { // Trimmed content encoding is empty when the header // value is set to "aws-chunked" only. // Make sure to delete the content-encoding parameter
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
cmd/metrics-v2.go
Description: m.Description, Value: m.Value, HistogramBucketLabel: m.HistogramBucketLabel, StaticLabels: make(map[string]string, len(m.StaticLabels)), VariableLabels: make(map[string]string, len(m.VariableLabels)), Histogram: make(map[string]uint64, len(m.Histogram)), } for k, v := range m.StaticLabels { metric.StaticLabels[k] = v }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0)