- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for NewClient (0.16 sec)
-
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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
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) -
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) -
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 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
if err := sa.AddReaderKubeSource([]local.ReaderSource{{Name: "", Reader: strings.NewReader(wh)}}); err != nil { return err } k, err := kube.NewClient(kube.NewClientConfigForRestConfig(config), "") if err != nil { return err } sa.AddRunningKubeSourceWithRevision(k, revision, false) res, err := sa.Analyze(make(chan struct{})) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0)