- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 82 for resource (0.19 sec)
-
cmd/namespace-lock.go
resource := pathJoin(volume, path) n.lockMapMutex.Lock() defer n.lockMapMutex.Unlock() if _, found := n.lockMap[resource]; !found { return } if readLock { n.lockMap[resource].RUnlock() } else { n.lockMap[resource].Unlock() } n.lockMap[resource].ref-- if n.lockMap[resource].ref < 0 { logger.CriticalIf(GlobalContext, errors.New("resource reference count was lower than 0"))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
// Gather the statuses before printing so they may be sorted mappedResp := map[string]string{} for id, dr := range drs { for _, resource := range dr.Resources { if s.InternalDebugAllIstiod { mappedResp[id] = string(resource.Value) + "\n" } else { _, _ = s.Writer.Write(resource.Value) _, _ = s.Writer.Write([]byte("\n")) } } } if len(mappedResp) > 0 {
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/admin/istiodconfig_test.go
args: args{ ctrzClient: ctrzClient, reset: false, outputLogLevel: "resource:info", stackTraceLevel: "", outputFormat: "", }, want: &istiodConfigLog{state: &logLevelState{ client: ctrzClient, outputLogLevel: "resource:info", }}, }, { name: "given --stack-trace-level flag return stackTraceLevelState", args: args{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 6.2K bytes - Viewed (0) -
cmd/namespace-lock_test.go
// 1) lk3 or lk4 need to advance and increment the ref on the existing resource, // successfully acquiring the lock. // 2) lk2 then needs to advance and remove the resource from lockMap. // 3) lk3 or lk4 (whichever didn't execute in step 1) then executes and creates // a new entry in lockMap and acquires a lock for the same resource. <-lk2ch lk3ok := <-lk3ch lk4ok := <-lk4ch if lk3ok && lk4ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.1K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
cmd := &cobra.Command{ Use: "check-inject [<type>/]<name>[.<namespace>]", Short: "Check the injection status or inject-ability of a given resource, explains why it is (or will be) injected or not", Long: ` Checks associated resources of the given resource, and running webhooks to examine whether the pod can be or will be injected or not.`, Example: ` # Check the injection status of a pod
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/dsync/locker.go
// In that case, the resource may or may not be unlocked. RUnlock(ctx context.Context, args LockArgs) (bool, error) // Do write unlock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of unlock request operation. // Canceling the context will abort the remote call. // In that case, the resource may or may not be unlocked.
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/metrics-v3-system-cpu.go
cpuNiceVal := math.Round(ts.Nice/tot*100*100) / 100 m.Set(sysCPUNice, cpuNiceVal) cpuStealVal := math.Round(ts.Steal/tot*100*100) / 100 m.Set(sysCPUSteal, cpuStealVal) // metrics-resource.go runs a job to collect resource metrics including their Avg values and // stores them in resourceMetricsMap. We can use it to get the Avg values of CPU idle and IOWait. cpuResourceMetrics, found := resourceMetricsMap[cpuSubsystem] if found {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 3K bytes - Viewed (0) -
istioctl/pkg/cli/kubectl_factory.go
import ( "k8s.io/apimachinery/pkg/api/meta" "k8s.io/cli-runtime/pkg/resource" openapiclient "k8s.io/client-go/openapi" "k8s.io/kubectl/pkg/cmd/util" "k8s.io/kubectl/pkg/util/openapi" "k8s.io/kubectl/pkg/validation" "istio.io/istio/pkg/kube" ) type Factory struct { kube.PartialFactory full util.Factory } func (f Factory) NewBuilder() *resource.Builder { return f.full.NewBuilder() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 2K bytes - Viewed (0) -
istioctl/pkg/writer/compare/sds/writer.go
case TABULAR: err = w.printSecretItemsTabular(secrets) } return err } var ( secretItemColumns = []string{"RESOURCE NAME", "TYPE", "STATUS", "VALID CERT", "SERIAL NUMBER", "NOT AFTER", "NOT BEFORE"} secretDiffColumns = []string{"RESOURCE NAME", "TYPE", "VALID CERT", "NODE AGENT", "PROXY", "SERIAL NUMBER", "NOT AFTER", "NOT BEFORE"} ) // printSecretItemsTabular prints the secret in table format
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 21 14:17:23 GMT 2023 - 4.1K bytes - Viewed (0) -
istioctl/pkg/version/version.go
return func() (*[]istioVersion.ProxyInfo, error) { pi := []istioVersion.ProxyInfo{} for _, resource := range (*xdsResponse).Resources { switch resource.TypeUrl { case "type.googleapis.com/envoy.config.core.v3.Node": node := core.Node{} err := resource.UnmarshalTo(&node) if err != nil { return nil, fmt.Errorf("could not unmarshal Node: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.3K bytes - Viewed (0)