- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for inspire (0.15 sec)
-
cni/pkg/nodeagent/podcgroupns_test.go
} expectedUID := "863b91d4-4b68-4efa-917f-4b560e3e86aa" if podUIDNetns[expectedUID] == (WorkloadInfo{}) { t.Fatal("expected to find pod netns under pod uid") } } // copied and modified from spire func TestGetContainerIDFromCGroups(t *testing.T) { makeCGroups := func(groupPaths []string) []Cgroup { var out []Cgroup for _, groupPath := range groupPaths { out = append(out, Cgroup{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
if err != nil { return nil, fmt.Errorf("error configuring iptables: %w", err) } // Create hostprobe rules now, in the host netns // Later we will reuse this same configurator inside the pod netns for adding other rules iptablesConfigurator.DeleteHostRules() if err := iptablesConfigurator.CreateHostRulesForHealthChecks(&HostProbeSNATIP, &HostProbeSNATIPV6); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
for _, collectorPath := range h.metricsData.collectorPaths { if collectorPath.isDescendantOf(path) { gatherer := h.metricsData.mgGatherers[collectorPath] // For Bucket metrics we need to set the buckets argument inside the // metric group, so that it will affect collection. If no buckets // are provided, we will not return bucket metrics. if bmg, ok := h.metricsData.bucketMGMap[collectorPath]; ok { if len(buckets) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
} return openNetns, nil } // AddPodToMesh adds a pod to mesh by // 1. Getting the netns // 2. Adding the pod's IPs to the hostnetns ipsets for node probe checks // 3. Creating iptables rules inside the pod's netns // 4. Notifying ztunnel via GRPC to create a proxy for the pod // // You may ask why we pass the pod IPs separately from the pod manifest itself (which contains the pod IPs as a field)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/metrics-resource.go
} func getResourceKey(name MetricName, labels map[string]string) string { // labels are used to uniquely identify a metric // e.g. reads_per_sec_{drive} inside the map sfx := "" for _, v := range labels { if len(sfx) > 0 { sfx += "_" } sfx += v } return string(name) + "_" + sfx }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/object-api-utils.go
const sseDAREEncPackageBlockSize = SSEDAREPackageBlockSize + SSEDAREPackageMetaSize // Number of full blocks in skipped area seqNum = uint32(compOff / SSEDAREPackageBlockSize) // Skip this many inside a decrypted block to get to compression block start decryptSkip = compOff % SSEDAREPackageBlockSize // Skip this number of full blocks. skipEnc := compOff / SSEDAREPackageBlockSize
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cni/pkg/nodeagent/netns_other.go
} func NetnsSet(n NetnsFd) error { return errors.New("not implemented") } func OpenNetns(nspath string) (NetnsCloser, error) { return nil, errors.New("not implemented") } // inspired by netns.Do() but with an existing fd. func NetnsDo(fdable NetnsFd, toRun func() error) error { return errors.New("not implemented")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 14 09:32:25 GMT 2024 - 1K bytes - Viewed (0) -
cmd/update-notifier.go
} // Return the nicely colored and formatted update message. return colorizeUpdateMessage(downloadURL, newerThan) } // colorizeUpdateMessage - inspired from Yeoman project npm package https://github.com/yeoman/update-notifier func colorizeUpdateMessage(updateString string, newerThan string) string { msgLine1Fmt := " You are running an older version of MinIO released %s "
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 3.6K bytes - Viewed (0) -
cmd/post-policy_test.go
if !globalBrowserEnabled { globalBrowserEnabled = true defer func() { globalBrowserEnabled = false }() } // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() req, perr := newPostRequestV4("", bucketName, objectName, []byte("pwned"), credentials.AccessKey, credentials.SecretKey) if perr != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
if oi.DeleteMarker != object.addDeleteMarker { t.Fatalf("Expected, marker %t : got %t", object.addDeleteMarker, oi.DeleteMarker) } } } // Formulating the result data set to be expected from ListObjects call inside the tests, // This will be used in testCases and used for asserting the correctness of ListObjects output in the tests. resultCases := []ListObjectsInfo{ { IsTruncated: false,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0)