- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for Retriever (0.21 sec)
-
istioctl/pkg/proxystatus/proxystatus.go
statusCmd := &cobra.Command{ Use: "proxy-status [<type>/]<name>[.<namespace>]", Short: "Retrieves the synchronization status of each Envoy in the mesh", Long: ` Retrieves last sent and last acknowledged xDS sync from Istiod to each Envoy in the mesh `, Example: ` # Retrieve sync status for all Envoys in a mesh istioctl proxy-status # Retrieve sync status for Envoys in a specific namespace istioctl proxy-status --namespace foo
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
Use: "internal-debug [<type>/]<name>[.<namespace>]", Short: "Retrieves the debug information of istio", Long: ` Retrieves the debug information from Istiod or Pods in the mesh using the service account from the pod if --cert-dir is empty. By default it will use the default serviceAccount from (istio-system) namespace if the pod is not specified. `, Example: ` # Retrieve sync status for all Envoys in a mesh istioctl x internal-debug syncz
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
chainable_api.go
Column: clause.Column{Name: v, Raw: true}, }}, }) } } return } // Limit specify the number of records to be retrieved // // Limit conditions can be cancelled by using `Limit(-1)`. // // // retrieve 3 users // db.Limit(3).Find(&users) // // retrieve 3 users into users1, and all users into users2 // db.Limit(3).Find(&users1).Limit(-1).Find(&users2) func (db *DB) Limit(limit int) (tx *DB) {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Apr 17 03:38:55 GMT 2024 - 14.3K bytes - Viewed (1) -
cmd/bucket-quota.go
if len(dui.BucketsUsage) > 0 { internalLogOnceIf(GlobalContext, fmt.Errorf("unable to retrieve usage information for bucket: %s, relying on older value cached in-memory: err(%v)", bucket, err), "bucket-usage-cache-"+bucket) } else { internalLogOnceIf(GlobalContext, errors.New("unable to retrieve usage information for bucket: %s, no reliable usage value available - quota will not be enforced"), "bucket-usage-empty-"+bucket) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.3K bytes - Viewed (0) -
internal/handlers/proxy.go
protoRegex = regexp.MustCompile(`(?i)^(;|,| )+(?:proto=)(https|http)`) ) // GetSourceScheme retrieves the scheme from the X-Forwarded-Proto and RFC7239 // Forwarded headers (in that order). func GetSourceScheme(r *http.Request) string { var scheme string // Retrieve the scheme from X-Forwarded-Proto. if proto := r.Header.Get(xForwardedProto); proto != "" { scheme = strings.ToLower(proto)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 5.1K bytes - Viewed (0) -
cmd/iam-etcd-store.go
m[policy] = p return nil } func (ies *IAMEtcdStore) loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error { ctx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() // Retrieve all keys and values to avoid too many calls to etcd in case of // a large number of policies r, err := ies.client.Get(ctx, iamConfigPoliciesPrefix, etcd.WithPrefix()) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/etcd.go
timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() resp, err := client.Get(timeoutCtx, key) if err != nil { etcdLogOnceIf(ctx, err, "etcd-retrieve-keys") return nil, etcdErrToErr(err, client.Endpoints()) } if resp.Count == 0 { return nil, errConfigNotFound } for _, ev := range resp.Kvs { if string(ev.Key) == key { return ev.Value, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
internal/config/cache/cache.go
// Config represents the subnet related configuration type Config struct { // Flag indicating whether cache is enabled. Enable bool `json:"enable"` // Endpoint for caching uses remote mcache server to // store and retrieve pre-condition check entities such as // Etag and ModTime of an object + version Endpoint string `json:"endpoint"` // BlockSize indicates the maximum object size below which
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
periodicTimer.Reset(time.Minute * 5) case <-ctx.Done(): // server could be restarting - need // to exit immediately return } } } // getHealSequenceByToken - Retrieve a heal sequence by token. The second // argument returns if a heal sequence actually exists. func (ahs *allHealState) getHealSequenceByToken(token string) (h *healSequence, exists bool) { ahs.RLock() defer ahs.RUnlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/metrics-resource.go
latestDriveStats map[string]madmin.DiskIOStats latestDriveStatsMu sync.RWMutex lastDriveStatsRefresh time.Time ) // PeerResourceMetrics represents the resource metrics // retrieved from a peer, along with errors if any type PeerResourceMetrics struct { Metrics map[MetricSubsystem]ResourceMetrics Errors []string } // ResourceMetrics is a map of unique key identifying
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0)