- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 331 for do (0.18 sec)
-
internal/disk/directio_unsupported.go
package disk import ( "os" ) // ODirectPlatform indicates if the platform supports O_DIRECT const ODirectPlatform = false // OpenBSD, Windows, and illumos do not support O_DIRECT. // On Windows there is no documentation on disabling O_DIRECT. // For these systems we do not attempt to build the 'directio' dependency since // the O_DIRECT symbol may not be exposed resulting in a failed build. // //
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 2.6K bytes - Viewed (0) -
internal/disk/fdatasync_linux.go
// do not require flushing because they are not necessary for a subsequent data // read to be handled correctly. On the other hand, a change to the file size // (st_size, as made by say ftruncate(2)), would require a metadata flush. // // The aim of fdatasync() is to reduce disk activity for applications that // do not require all metadata to be synchronized with the disk.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Sep 29 23:40:28 GMT 2021 - 1.8K bytes - Viewed (0) -
internal/logger/legacy.go
) // SetLoggerHTTPAudit - helper for migrating older config to newer KV format. func SetLoggerHTTPAudit(scfg config.Config, k string, args http.Config) { if !args.Enabled { // Do not enable audit targets, if not enabled return } scfg[config.AuditWebhookSubSys][k] = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: Endpoint,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Aug 03 09:47:07 GMT 2023 - 2K bytes - Viewed (1) -
cni/pkg/iptables/iptables.go
// NOTE that this expects to be run from within the HOST network namespace! // // We need to do this specifically to be able to distinguish between traffic coming from different node-level processes // via the nodeIP // - kubelet (node-local healthchecks, which we do not capture) // - kube-proxy (fowarded/proxied traffic from LoadBalancer-backed services, potentially with public IPs, which we must capture)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 01:42:30 GMT 2024 - 19.2K bytes - Viewed (0) -
internal/event/target/redis.go
if args.User != "" { if _, err = conn.Do("AUTH", args.User, args.Password); err != nil { conn.Close() return nil, err } } else { if _, err = conn.Do("AUTH", args.Password); err != nil { conn.Close() return nil, err } } } // Must be done after AUTH if _, err = conn.Do("CLIENT", "SETNAME", "MinIO"); err != nil { conn.Close()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/event/target/mqtt.go
} // SendFromStore - reads an event from store and sends it to MQTT. func (target *MQTTTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } // Do not send if the connection is not active. _, err := target.isActive() if err != nil { return err } eventData, err := target.store.Get(key.Name) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
istioctl/cmd/istioctl_test.go
switch fErr.(type) { case istioctlutil.CommandParseError: // do nothing default: t.Errorf("Expected a CommandParseError, but got %q.", fErr) } // we should propagate to subcommands rootCmd = GetRootCmd([]string{"analyze", "--unknown-flag"}) fErr = rootCmd.Execute() switch fErr.(type) { case istioctlutil.CommandParseError: // do nothing default:
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:53:25 GMT 2023 - 1.5K bytes - Viewed (0) -
cmd/batchjobmetric_string.go
// Code generated by "stringer -type=batchJobMetric -trimprefix=batchJobMetric batch-handlers.go"; DO NOT EDIT. package cmd import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[batchJobMetricReplication-0] _ = x[batchJobMetricKeyRotation-1] _ = x[batchJobMetricExpire-2] }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 797 bytes - Viewed (0) -
cmd/rebalstatus_string.go
// Code generated by "stringer -type=rebalStatus -trimprefix=rebal erasure-server-pool-rebalance.go"; DO NOT EDIT. package cmd import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[rebalNone-0] _ = x[rebalStarted-1] _ = x[rebalCompleted-2] _ = x[rebalStopped-3] _ = x[rebalFailed-4] }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Oct 25 19:36:57 GMT 2022 - 795 bytes - Viewed (0) -
cmd/auth-handler_test.go
t.Fatalf("Unable to initialize new http request %s", err) } return req } // This is similar to mustNewRequest but additionally the request // is signed with AWS Signature V4, fails if not able to do so. func mustNewSignedRequest(method string, urlStr string, contentLength int64, body io.ReadSeeker, t *testing.T) *http.Request { req := mustNewRequest(method, urlStr, contentLength, body, t) cred := globalActiveCred
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 15.4K bytes - Viewed (0)