- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 249 for server1 (0.15 sec)
-
cmd/net.go
localHost, err := isLocalHost(host.Name, host.Port.String(), host.Port.String()) if err != nil { return err } if !localHost { return config.ErrInvalidAddressFlag(nil).Msg("host in server address should be this server") } } return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/dsync/locker.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
signedHeaders = append(signedHeaders, "x-amz-server-side-encryption") // expect to fail with `ErrUnsignedHeaders` because couldn't find some header _, errCode = extractSignedHeaders(signedHeaders, r) if errCode != ErrUnsignedHeaders { t.Fatalf("Expected the APIErrorCode to %d, but got %d", ErrUnsignedHeaders, errCode) } // set headers value through Get parameter inputQuery.Add("x-amz-server-side-encryption", xhttp.AmzEncryptionAES)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0) -
cmd/metacache-server-pool.go
} // We have 2 cases: // 1) Cold listing, just list. // 2) Returning, but with no id. Start async listing. // 3) Returning, with ID, stream from list. // // If we don't have a list id we must ask the server if it has a cache or create a new. if o.ID != "" && !o.Transient { // Create or ping with handout... rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) var c *metacache if rpc == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/config/constants.go
EnvMinIOSubnetProxy = "MINIO_SUBNET_PROXY" EnvMinIOCallhomeEnable = "MINIO_CALLHOME_ENABLE" EnvMinIOCallhomeFrequency = "MINIO_CALLHOME_FREQUENCY" EnvMinIOServerURL = "MINIO_SERVER_URL" EnvBrowserRedirect = "MINIO_BROWSER_REDIRECT" // On by default EnvBrowserRedirectURL = "MINIO_BROWSER_REDIRECT_URL" EnvRootDriveThresholdSize = "MINIO_ROOTDRIVE_THRESHOLD_SIZE"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 01 16:36:33 GMT 2024 - 3.4K bytes - Viewed (3) -
cmd/metacache-manager.go
return errFileNotFound } if cache.status == scanStateSuccess || cache.status == scanStateStarted { if time.Since(cache.lastUpdate) > metacacheMaxRunningAge { // We got a stale entry, mark error on handling server. err := fmt.Errorf("timeout: list %s not updated", cache.id) cache.error = err.Error() cache.status = scanStateError rpc.UpdateMetacacheListing(ctx, cache) return err } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
# Retrieve syncz debug information directly from the control plane, using RSA certificate security # (Certificates must be obtained before this step. The --cert-dir flag lets istioctl bypass the Kubernetes API server.) istioctl x internal-debug syncz --xds-address istio.example.com:15012 --cert-dir ~/.istio-certs # Retrieve syncz information via XDS from specific control plane in multi-control plane in-cluster configuration
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
# Retrieve proxy status information directly from the control plane, using RSA certificate security # (Certificates must be obtained before this step. The --cert-dir flag lets istioctl bypass the Kubernetes API server.) istioctl ps --xds-address istio.example.com:15012 --cert-dir ~/.istio-certs # Retrieve proxy status information via XDS from specific control plane in multi-control plane in-cluster configuration
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
internal/event/target/nsq.go
} if err := target.send(eventData); err != nil { return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - closes underneath connections to NSQD server. func (target *NSQTarget) Close() (err error) { close(target.quitCh) if target.producer != nil { // this blocks until complete: target.producer.Stop() } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
} return promhttp.HandlerFor(prometheus.Gatherers(gatherers), h.opts) } // ServeHTTP - implements http.Handler interface. // // When the `list` query parameter is provided (its value is ignored), the // server lists all metrics that could be returned for the requested path. // // The (repeatable) `buckets` query parameter is a list of bucket names (or it // could be a comma separated value) to return metrics with a bucket label.
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)