- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 262 for clients (0.19 sec)
-
internal/etag/etag.go
// existing ETag entry. // // Due to legacy S3 clients, that make incorrect assumptions // about HTTP headers, Set should be used instead of // http.Header.Set(...). Otherwise, some S3 clients will not // able to extract the ETag. func Set(etag ETag, h http.Header) { // Some (broken) S3 clients expect the ETag header to // literally "ETag" - not "Etag". Further, some clients // expect an ETag in double quotes. Therefore, we set the
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
} type Client struct { client kube.Client remote bool } func getClients(ctx cli.Context) ([]*Client, error) { client, err := ctx.CLIClient() if err != nil { return nil, err } clients := []*Client{ { client: client, remote: false, }, }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// Add total timeout ctx, cancel := context.WithTimeout(ctx, opts.Timeout) defer cancel() // Tolerance is not set, defaults to half of the locker clients. tolerance := len(restClnts) / 2 // Quorum is effectively = total clients subtracted with tolerance limit quorum := len(restClnts) - tolerance if !isReadLock { // In situations for write locks, as a special case
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/routers.go
// accordingly. Client receives a HTTP error for invalid/unsupported // signatures. // // Validates all incoming requests to have a valid date header. setAuthMiddleware, // Redirect some pre-defined browser request paths to a static location // prefix. setBrowserRedirectMiddleware, // Adds 'crossdomain.xml' policy middleware to serve legacy flash clients. setCrossDomainPolicyMiddleware,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
internal/http/dial_linux.go
// https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/ // This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can // affect clients reading data with a very slow pace (disappropriate with socket buffer sizes) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT, opts.UserTimeout) if opts.Interface != "" {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Jun 07 16:53:05 GMT 2023 - 4.4K bytes - Viewed (3) -
internal/grid/grid.go
biggerBufMax = maxBufferSize // If there is a queue, merge up to this many messages. maxMergeMessages = 30 // clientPingInterval will ping the remote handler every 15 seconds. // Clients disconnect when we exceed 2 intervals. clientPingInterval = 15 * time.Second // Deadline for single (non-streaming) requests to complete. // Used if no deadline is provided on context.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
istioctl/pkg/cli/context.go
} func (i *instance) CLIClientWithRevision(rev string) (kube.CLIClient, error) { if i.clients == nil { i.clients = make(map[string]kube.CLIClient) } if i.clients[rev] == nil { client, err := newKubeClientWithRevision(*i.kubeconfig, *i.configContext, rev) if err != nil { return nil, err } i.clients[rev] = client } return i.clients[rev], nil } func (i *instance) CLIClient() (kube.CLIClient, error) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/object-handlers-common.go
// to activate delete only headers set delete as true func setPutObjHeaders(w http.ResponseWriter, objInfo ObjectInfo, delete bool) { // We must not use the http.Header().Set method here because some (broken) // clients expect the ETag header key to be literally "ETag" - not "Etag" (case-sensitive). // Therefore, we have to set the ETag directly as map entry. if objInfo.ETag != "" && !delete {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 09 08:17:49 GMT 2024 - 14.6K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
func run(c *cobra.Command, ctx cli.Context, args []string) error { log.Debugf("metrics command invoked for workload(s): %v", args) client, err := ctx.CLIClientWithRevision(metricsOpts.Revision) if err != nil { return fmt.Errorf("failed to create k8s client: %v", err) } pl, err := client.PodsForSelector(context.TODO(), ctx.IstioNamespace(), "app.kubernetes.io/name=prometheus") if err != 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) -
cmd/http-stats.go
if toLower { k = strings.ToLower(k) } apiStats[k] = v } return apiStats } // HTTPStats holds statistics information about // HTTP requests made by all clients type HTTPStats struct { s3RequestsInQueue int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG _ int32 // For 64 bits alignment s3RequestsIncoming uint64
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0)