- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Blades (0.23 sec)
-
cni/pkg/nodeagent/informers.go
// // NOTE that we are requeueing namespaces here explicitly to work around // test flakes with the fake kube client in `pkg/kube/client.go` - // because we are using `List()` in the handler, without this requeue, // the fake client will sometimes drop pod events leading to test flakes. // // WaitForCacheSync *helps*, but does not entirely fix this problem
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0) -
internal/config/errors-utils.go
return e } // ErrFn function wrapper type ErrFn func(err error) Err // Create a UI error generator, this is needed to simplify // the update of the detailed error message in several places // in MinIO code func newErrFn(msg, action, hint string) ErrFn { return func(err error) Err { u := Err{ msg: msg, action: action, hint: hint, } if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/api-headers.go
// to support AWS S3 compatible behavior. // // Do not use this function for anything other than ListObjects() // variants, please open a github discussion if you wish to use // this in other places. func encodeResponseList(response interface{}) []byte { var buf bytes.Buffer buf.WriteString(xxml.Header) if err := xxml.NewEncoder(&buf).Encode(response); err != nil { bugLogIf(GlobalContext, err) return nil
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.9K bytes - Viewed (1) -
istioctl/pkg/tag/revision.go
} func ListRevisionDescriptions(client kube.CLIClient) (map[string]*RevisionDescription, error) { revisions := map[string]*RevisionDescription{} // Get a list of control planes which are installed in remote clusters // In this case, it is possible that they only have webhooks installed. webhooks, err := Webhooks(context.Background(), client) if err != nil {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Jan 28 13:16:05 GMT 2023 - 4.5K bytes - Viewed (0) -
cmd/config-migrate.go
return nil, err } continue } data, _ = json.Marshal(cfg) break } if osIsPermission(err) { logger.Info("Older config found but is not readable %s, proceeding to read config from other places", err) } if osIsNotExist(err) || osIsPermission(err) || len(data) == 0 { data, err = readConfig(GlobalContext, objAPI, configFile) if err != nil { // when config.json is not found, then we freshly initialize.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Oct 18 18:05:24 GMT 2023 - 5.4K bytes - Viewed (0) -
src/cmd/cgo/doc.go
automatically defined in the preamble. Note that there is no way for C code to create a value of this type; this is only useful for passing string values from Go to C and back to Go. Using //export in a file places a restriction on the preamble: since it is copied into two different C output files, it must not contain any definitions, only declarations. If a file contains both
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Sun Mar 31 09:02:45 GMT 2024 - 42.1K bytes - Viewed (0) -
cmd/bucket-handlers.go
UserAgent: r.UserAgent(), Host: handlers.GetSourceIP(r), }) } // PutBucketObjectLockConfigHandler - PUT Bucket object lock configuration. // ---------- // Places an Object Lock configuration on the specified bucket. The rule // specified in the Object Lock configuration will be applied by default // to every new object placed in the specified bucket.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
cni/pkg/repair/netns.go
// under the procfs, /proc/<pid>/ns/net. In majority of cases, this is not used directly, but is rather bind mounted to // /var/run/netns/<name>. However, this pattern is not ubiquitous. Some platforms bind mount to other places. As we run // in a pod, we cannot just access any arbitrary file they happen to bind mount in, as we don't know ahead of time where // it might be. // // Instead, we rely directly on the procfs.
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
func createMeshConfig(kubeClient kube.CLIClient, wg *clientv1alpha3.WorkloadGroup, istioNamespace, clusterID, dir, revision string, ) (*meshconfig.ProxyConfig, error) { istioCM := "istio" // Case with multiple control planes if isRevisioned(revision) { istioCM = fmt.Sprintf("%s-%s", istioCM, revision) } istio, err := kubeClient.Kube().CoreV1().ConfigMaps(istioNamespace).Get(context.Background(), istioCM, metav1.GetOptions{})
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex.go
// A TokenReader is like a reader, but returns lex tokens of type Token. It also can tell you what // the text of the most recently returned token is, and where it was found. // The underlying scanner elides all spaces except newline, so the input looks like a stream of // Tokens; original spacing is lost but we don't need it. type TokenReader interface { // Next returns the next token. Next() ScanToken
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Aug 29 18:31:05 GMT 2023 - 4.1K bytes - Viewed (0)