- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for Magenta (0.16 sec)
-
logger/logger.go
warnStr = BlueBold + "%s\n" + Reset + Magenta + "[warn] " + Reset errStr = Magenta + "%s\n" + Reset + Red + "[error] " + Reset traceStr = Green + "%s\n" + Reset + Yellow + "[%.3fms] " + BlueBold + "[rows:%v]" + Reset + " %s" traceWarnStr = Green + "%s " + Yellow + "%s\n" + Reset + RedBold + "[%.3fms] " + Yellow + "[rows:%v]" + Magenta + " %s" + Reset
Go - Registered: Sun Apr 21 09:35:09 GMT 2024 - Last Modified: Tue Nov 07 02:19:41 GMT 2023 - 5.8K bytes - Viewed (0) -
internal/s3select/select_test.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 76.2K bytes - Viewed (0) -
internal/config/policy/opa/config.go
return err } oa := Args(so) if oa.URL == nil || oa.URL.String() == "" { *a = oa return nil } *a = oa return nil } // Opa - implements opa policy agent calls. type Opa struct { args Args client *http.Client } // Enabled returns if opa is enabled. func Enabled(kvs config.KVS) bool { return kvs.Get(URL) != "" }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.2K bytes - Viewed (1) -
cmd/api-response.go
func writeErrorResponse(ctx context.Context, w http.ResponseWriter, err APIError, reqURL *url.URL) { if err.HTTPStatusCode == http.StatusServiceUnavailable { // Set retry-after header to indicate user-agents to retry request after 120secs. // https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Retry-After w.Header().Set(xhttp.RetryAfter, "120") } switch err.Code { case "InvalidRegion":
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
cmd/post-policy_test.go
contentTypeHdr := req.Header.Get("Content-Type") contentTypeHdr = strings.Replace(contentTypeHdr, "multipart/form-data", "multipart/form-datA", 1) req.Header.Set("Content-Type", contentTypeHdr) req.Header.Set("User-Agent", "Mozilla") // Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler. // Call the ServeHTTP to execute the handler. apiRouter.ServeHTTP(rec, req)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cni/pkg/cmd/root.go
if cfg.InstallConfig.AmbientEnabled { // Start ambient controller // node agent will spawn a goroutine and watch the K8S API for events, // as well as listen for messages from the CNI binary. log.Info("Starting ambient node agent with inpod redirect mode") ambientAgent, err := nodeagent.NewServer(ctx, watchServerReady, cfg.InstallConfig.CNIEventAddress, nodeagent.AmbientArgs{
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 21:42:29 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/update.go
return err != nil } // IsPCFTile returns if server is running in PCF func IsPCFTile() bool { return env.Get("MINIO_PCF_TILE_VERSION", "") != "" } // DO NOT CHANGE USER AGENT STYLE. // The style should be // // MinIO (<OS>; <ARCH>[; <MODE>][; dcos][; kubernetes][; docker][; source]) MinIO/<VERSION> MinIO/<RELEASE-TAG> MinIO/<COMMIT-ID> [MinIO/universe-<PACKAGE-NAME>] [MinIO/helm-<HELM-VERSION>] //
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 18.7K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/serviceregistry/kube/controller" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/config/validation/agent" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/labels" "istio.io/istio/pkg/log" netutil "istio.io/istio/pkg/util/net" "istio.io/istio/pkg/util/protomarshal" "istio.io/istio/pkg/util/shellescape" )
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) -
cni/pkg/nodeagent/podcgroupns.go
// descendants of a kubepods directory, however, as of Kubernetes 1.21, cgroups // namespaces are in use and therefore we can no longer discern if that is the // case from within SPIRE agent container (since the container itself is // namespaced). As such, the regex has been relaxed to simply find the pod UID // followed by the container ID with allowances for arbitrary punctuation, and
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
statusCmd.PersistentFlags().BoolVar(&multiXdsOpts.XdsViaAgents, "xds-via-agents", false, "Access Istiod via the tap service of each agent") statusCmd.PersistentFlags().IntVar(&multiXdsOpts.XdsViaAgentsLimit, "xds-via-agents-limit", 100, "Maximum number of pods being visited by istioctl when `xds-via-agent` flag is true."+ "To iterate all the agent pods without limit, set to 0") return statusCmd
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0)