Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getAdminClient (0.12 sec)

  1. cmd/site-replication.go

    	)
    
    	for _, v := range sites {
    		if v.self {
    			continue
    		}
    		switch {
    		case currDeploymentIDsSet.Contains(v.DeploymentID):
    			admClient, err = c.getAdminClient(ctx, v.DeploymentID)
    		default:
    			admClient, err = getAdminClient(v.Endpoint, v.AccessKey, v.SecretKey)
    		}
    		if err != nil {
    			peerAddErr = errSRPeerResp(fmt.Errorf("unable to create admin client for %s: %w", v.Name, err))
    			break
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  2. cmd/perf-tests.go

    func perfNetRequest(ctx context.Context, deploymentID, reqPath string, reader io.Reader) (result madmin.SiteNetPerfNodeResult) {
    	result = madmin.SiteNetPerfNodeResult{}
    	cli, err := globalSiteReplicationSys.getAdminClient(ctx, deploymentID)
    	if err != nil {
    		result.Error = err.Error()
    		return
    	}
    	rp := cli.GetEndpointURL()
    	reqURL := &url.URL{
    		Scheme: rp.Scheme,
    		Host:   rp.Host,
    		Path:   reqPath,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. cmd/admin-handlers-users_test.go

    		s.setUpEtcd(c, etcdServer)
    	}
    }
    
    func (s *TestSuiteIAM) RestartIAMSuite(c *check) {
    	s.TestSuiteCommon.RestartTestServer(c)
    
    	s.iamSetup(c)
    }
    
    func (s *TestSuiteIAM) getAdminClient(c *check, accessKey, secretKey, sessionToken string) *madmin.AdminClient {
    	madmClnt, err := madmin.NewWithOptions(s.endpoint, &madmin.Options{
    		Creds:  credentials.NewStaticV4(accessKey, secretKey, sessionToken),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
Back to top