Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewClient (0.46 sec)

  1. common/config/.golangci.yml

        - linters:
            - staticcheck
          text: 'SA1019: grpc.Dial is deprecated: use NewClient instead'
        - linters:
            - staticcheck
          text: 'SA1019: grpc.DialContext is deprecated: use NewClient instead'
      # Independently from option `exclude` we use default exclude patterns,
      # it can be disabled by this option. To list all
    Others
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Apr 22 19:22:39 GMT 2024
    - 11K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    		config.QPS = 80
    		config.Burst = 160
    	})
    	if err != nil {
    		return nil, fmt.Errorf("failed creating kube config: %v", err)
    	}
    
    	client, err := kube.NewClient(kube.NewClientConfigForRestConfig(kubeRestConfig), "")
    	if err != nil {
    		return nil, fmt.Errorf("failed creating kube client: %v", err)
    	}
    
    	return client, nil
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  3. cmd/warm-backend-gcs.go

    	}
    
    	credsJSON, err := conf.GetCredentialJSON()
    	if err != nil {
    		return nil, err
    	}
    
    	clnt := &http.Client{
    		Transport: globalRemoteTargetTransport,
    	}
    
    	client, err := storage.NewClient(context.Background(),
    		option.WithCredentialsJSON(credsJSON),
    		option.WithScopes(storage.ScopeReadWrite),
    		option.WithHTTPClient(clnt),
    		option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    		Host:   endpoint.Host,
    		Path:   path.Join(storageRESTPrefix, endpoint.Path, storageRESTVersion),
    	}
    
    	restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    
    	if healthCheck {
    		// Use a separate client to avoid recursive calls.
    		healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    		healthClient.NoMetrics = true
    		restClient.HealthCheckFn = func() bool {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  5. istioctl/pkg/metrics/metrics.go

    		}
    
    		printMetrics(c.OutOrStdout(), sm)
    	}
    	return nil
    }
    
    func prometheusAPI(address string) (promv1.API, error) {
    	promClient, err := api.NewClient(api.Config{Address: address})
    	if err != nil {
    		return nil, fmt.Errorf("could not build prometheus client: %v", err)
    	}
    	return promv1.NewAPI(promClient), nil
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 8.4K bytes
    - Viewed (0)
Back to top