Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 12 of 12 for NewClient (0.14 sec)

  1. internal/event/target/kafka_scram_client_contrib.go

    // SASLprep fails, the method returns an error.
    func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {
    	x.Client, err = x.HashGeneratorFcn.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.Client.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 5.9K bytes
    - Viewed (0)
Back to top