Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for newClient (0.12 sec)

  1. cmd/warm-backend-azure.go

    		return errors.New("no authentication mechanism was provided")
    	}
    
    	if conf.Bucket == "" {
    		return errors.New("no bucket name was provided")
    	}
    
    	return nil
    }
    
    func (conf azureConf) NewClient() (clnt *azblob.Client, clntErr error) {
    	if err := conf.Validate(); err != nil {
    		return nil, err
    	}
    
    	ep := conf.Endpoint
    	if ep == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  2. 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'
        - linters:
            - staticcheck
          text: "SA1019: grpc.WithBlock is deprecated"
        - linters:
            - staticcheck
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. internal/event/target/kafka.go

    	target.config = config
    
    	brokers := []string{}
    	for _, broker := range args.Brokers {
    		brokers = append(brokers, broker.String())
    	}
    
    	client, err := sarama.NewClient(brokers, config)
    	if err != nil {
    		if !errors.Is(err, sarama.ErrOutOfBrokers) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. internal/event/target/mqtt.go

    		SetMaxReconnectInterval(args.MaxReconnectInterval).
    		SetKeepAlive(args.KeepAlive).
    		SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}).
    		AddBroker(args.Broker.String())
    
    	target.client = mqtt.NewClient(options)
    
    	token := target.client.Connect()
    	ok := token.WaitTimeout(reconnectInterval)
    	if !ok {
    		return store.ErrNotConnected
    	}
    	if token.Error() != nil {
    		return token.Error()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  6. cmd/warm-backend-gcs.go

    	if conf.Bucket == "" {
    		return nil, errors.New("no bucket name was provided")
    	}
    
    	credsJSON, err := conf.GetCredentialJSON()
    	if err != nil {
    		return nil, err
    	}
    
    	client, err := storage.NewClient(context.Background(),
    		option.WithCredentialsJSON(credsJSON),
    		option.WithScopes(storage.ScopeReadWrite),
    		option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag),
    	)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. internal/logger/target/kafka/kafka.go

    	h.config = sconfig
    
    	var brokers []string
    	for _, broker := range h.kconfig.Brokers {
    		brokers = append(brokers, broker.String())
    	}
    
    	client, err := sarama.NewClient(brokers, sconfig)
    	if err != nil {
    		return err
    	}
    
    	producer, err := sarama.NewSyncProducerFromClient(client)
    	if err != nil {
    		return err
    	}
    	h.client = client
    	h.producer = producer
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  8. cmd/peer-rest-client.go

    	}
    
    	serverURL := &url.URL{
    		Scheme: scheme,
    		Host:   peer.String(),
    		Path:   peerRESTPath,
    	}
    
    	restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	// Use a separate client to avoid recursive calls.
    	healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	healthClient.NoMetrics = true
    
    	// Construct a new health function.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  9. internal/event/target/elasticsearch.go

    	}
    	// Set basic auth
    	if args.Username != "" && args.Password != "" {
    		elasticConfig.Username = args.Username
    		elasticConfig.Password = args.Password
    	}
    	// Create a client
    	client, err := elasticsearch7.NewClient(elasticConfig)
    	if err != nil {
    		return nil, err
    	}
    	clientV7 := &esClientV7{client}
    	return clientV7, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  10. 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
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top