- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 116 for Dost (0.14 sec)
-
cmd/storage-rest-server.go
// Windows can lock up with this optimization, so we fall back to regular copy. sr, ok := rc.(*sendFileReader) if ok { // Sendfile sends in 4MiB chunks per sendfile syscall which is more than enough // for most setups. _, err = rf.ReadFrom(sr.Reader) if !xnet.IsNetworkOrHostDown(err, true) { // do not need to log disconnected clients storageLogIf(r.Context(), err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
for _, hostname := range vs.Spec.Hosts { if host.Name(hostname).IsWildCarded() { res := ObjectToInstance(vs) messages.Add(msg.NewUpdateIncompatibility(res, "PERSIST_OLDEST_FIRST_HEURISTIC_FOR_VIRTUAL_SERVICE_HOST_MATCHING", "1.20", "previously, VirtualServices with overlapping wildcard hosts would have the oldest "+ "VirtualService take precedence. Now, the most specific VirtualService will win", "1.20"), )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/bucket-targets.go
defer sys.hMutex.RUnlock() if h, ok := sys.hc[ep.Host]; ok { return !h.Online } go sys.initHC(ep) return false } // markOffline sets endpoint to offline if network i/o timeout seen. func (sys *BucketTargetSys) markOffline(ep *url.URL) { sys.hMutex.Lock() defer sys.hMutex.Unlock() if h, ok := sys.hc[ep.Host]; ok { h.Online = false sys.hc[ep.Host] = h } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
internal/grid/msg_gen.go
case "ID": err = dc.ReadExactBytes((z.ID)[:]) if err != nil { err = msgp.WrapError(err, "ID") return } case "Host": z.Host, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Host") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 18.8K bytes - Viewed (0) -
internal/logger/config.go
} if !enabled { continue } var brokers []xnet.Host kafkaBrokers := getCfgVal(EnvKafkaBrokers, k, kv.Get(KafkaBrokers)) if len(kafkaBrokers) == 0 { return cfg, config.Errorf("kafka 'brokers' cannot be empty") } for _, s := range strings.Split(kafkaBrokers, config.ValueSeparator) { var host *xnet.Host host, err = xnet.ParseHost(s) if err != nil { break }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/kms-handlers.go
if err != nil { writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL) return } writeSuccessResponseJSON(w, resp) } // KMSMetricsHandler - POST /minio/kms/v1/metrics func (a kmsAPIHandlers) KMSMetricsHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "KMSMetrics") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/globals.go
} // MinIO local server address (in `host:port` format) globalMinioAddr = "" // MinIO default port, can be changed through command line. globalMinioPort = GlobalMinioDefaultPort globalMinioConsolePort = "13333" // Holds the host that was passed using --address globalMinioHost = "" // Holds the host that was passed using --console-address globalMinioConsoleHost = ""
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cni/pkg/cmd/root.go
Title: "Istio CNI Plugin Installer", Section: "install-cni CLI", Manual: "Istio CNI Plugin Installer", })) registerStringParameter(constants.CNINetDir, "/etc/cni/net.d", "Directory on the host where CNI network plugins are installed") registerStringParameter(constants.CNIConfName, "", "Name of the CNI configuration file")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
path := "logging" if param != "" { path = path + "?" + param } // "Envoy" applies despite this being ztunnel result, err := kubeClient.EnvoyDoWithPort(context.TODO(), podName, podNamespace, "POST", path, port) if err != nil { return "", fmt.Errorf("failed to execute command on Ztunnel: %v", err) } return string(result), nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
} if err = p.initializeProvider(getCfgVal, c.transport); err != nil { return c, err } arnKey := p.roleArn if p.RolePolicy == "" { arnKey = DummyRoleARN // Ensure that at most one JWT policy claim based provider may be // defined. if _, ok := c.arnProviderCfgsMap[DummyRoleARN]; ok { return c, errSingleProvider } } c.arnProviderCfgsMap[arnKey] = &p
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 16.5K bytes - Viewed (0)