- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 46 for Kahler (0.19 sec)
-
cmd/storage-rest-client.go
// transport is already down. return "", errDiskNotFound } // This call should never be over the network, this is always // a cached value - caller should make sure to use this // function on a fresh disk or make sure to look at the error // from a different networked call to validate the GetDiskID() return *client.diskID.Load(), nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
} }() err = s.getStorage().ReadMultiple(r.Context(), req, responses) wg.Wait() rw.CloseWithError(err) } // globalLocalSetDrives is used for local drive as well as remote REST // API caller for other nodes to talk to this node. // // Any updates to this must be serialized via globalLocalDrivesMu (locker) var globalLocalSetDrives [][][]StorageAPI
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) -
operator/cmd/mesh/test-util_test.go
} func mustSelect(t test.Failer, selector map[string]string, labels map[string]string) { t.Helper() kselector := labels2.Set(selector).AsSelectorPreValidated() if !kselector.Matches(labels2.Set(labels)) { t.Fatalf("%v does not select %v", selector, labels) } } func mustNotSelect(t test.Failer, selector map[string]string, labels map[string]string) { t.Helper()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 15.3K bytes - Viewed (0) -
internal/s3select/message.go
// // 1. If a writer.write() returns false, select loop below exits and // closes `doneCh` to indicate to caller to also exit. // // 2. If caller (Evaluate()) has an error, it sends an error // message and waits for this go-routine to quit in // FinishWithError() // // 3. If caller is done, it waits for this go-routine to exit // in Finish() quitFlag := false for !quitFlag { select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
src/builtin/builtin.go
// goroutine. When a function F calls panic, normal execution of F stops // immediately. Any functions whose execution was deferred by F are run in // the usual way, and then F returns to its caller. To the caller G, the // invocation of F then behaves like a call to panic, terminating G's // execution and running any deferred functions. This continues until all
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/update.go
// CRI-O, Containerd etc.. // Fallback to our container specific ENVs if they are set. return env.IsSet("MINIO_ACCESS_KEY_FILE") } // Log error, as we will not propagate it to caller internalLogIf(GlobalContext, err) return err == nil } // IsDCOS returns true if minio is running in DCOS. func IsDCOS() bool { // http://mesos.apache.org/documentation/latest/docker-containerizer/
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
istioctl/cmd/root.go
root.LoggingOptions.AttachCobraFlags(rootCmd) hiddenFlags := []string{ "log_as_json", "log_rotate", "log_rotate_max_age", "log_rotate_max_backups", "log_rotate_max_size", "log_stacktrace_level", "log_target", "log_caller", "log_output_level", } for _, opt := range hiddenFlags { _ = rootCmd.PersistentFlags().MarkHidden(opt) } cmd.AddFlags(rootCmd) kubeInjectCmd := kubeinject.InjectCommand(ctx)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
func Enabled(kvs config.KVS) bool { return kvs.Get(ConfigURL) != "" } // GetSettings - fetches OIDC settings for site-replication related validation. // NOTE that region must be populated by caller as this package does not know. func (r *Config) GetSettings() madmin.OpenIDSettings { res := madmin.OpenIDSettings{} if !r.Enabled { return res } h := sha256.New()
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) -
internal/grid/types.go
func NewBytesCap(size int) *Bytes { b := Bytes(GetByteBufferCap(size)) return &b } // NewBytesWith returns a new Bytes with the provided content. // When sent as a parameter, the caller gives up ownership of the byte slice. // When returned as response, the handler also gives up ownership of the byte slice. func NewBytesWith(b []byte) *Bytes { bb := Bytes(b) return &bb }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret_test.go
mustFindObject(t, objs, "istio-reader-clusterrole-istio-system", "ClusterRole") mustFindObject(t, objs, "istio-reader-clusterrole-istio-system", "ClusterRoleBinding") } func mustFindObject(t test.Failer, objs object.K8sObjects, name, kind string) { t.Helper() var obj *object.K8sObject for _, o := range objs { if o.Kind == kind && o.Name == name { obj = o break } } if obj == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 20.6K bytes - Viewed (0)