- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for reflection (0.16 sec)
-
cmd/api-router.go
// // The passed in handler function must be a method of `objectAPIHandlers` for // the name displayed in logs and trace to be accurate. The name is extracted // via reflection. // // When **no** flags are passed, the behavior is to trace both headers and body, // gzip the response and throttle the handler via `maxClients`. Each of these // can be disabled via the corresponding `s3HFlag`. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
cmd/api-utils.go
return s3URLEncode(name) } return name } // getHandlerName returns the name of the handler function. It takes the type // name as a string to clean up the name retrieved via reflection. This function // only works correctly when the type is present in the cmd package. func getHandlerName(f http.HandlerFunc, cmdType string) string { name := runtime.FuncForPC(reflect.ValueOf(f).Pointer()).Name()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/admin-router.go
// done per-"handler function registration" in the router. // // The passed in handler function must be a method of `adminAPIHandlers` for the // name displayed in logs and trace to be accurate. The name is extracted via // reflection. // // When no flags are passed, gzip compression, http tracing of headers and // checking of object layer availability are all enabled. Use flags to modify // this behavior.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
finisher_api.go
case reflect.Slice, reflect.Array: var rowsAffected int64 tx = db.getInstance() // the reflection length judgment of the optimized value reflectLen := reflectValue.Len() callFc := func(tx *DB) error { for i := 0; i < reflectLen; i += batchSize { ends := i + batchSize if ends > reflectLen { ends = reflectLen } subtx := tx.getInstance()
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 22.7K bytes - Viewed (0) -
schema/naming.go
} return ns.TablePrefix + inflection.Plural(ns.toDBName(str)) } // SchemaName generate schema name from table name, don't guarantee it is the reverse value of TableName func (ns NamingStrategy) SchemaName(table string) string { table = strings.TrimPrefix(table, ns.TablePrefix) if ns.SingularTable { return ns.toSchemaName(table) } return ns.toSchemaName(inflection.Singular(table)) }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Oct 30 09:15:49 GMT 2023 - 5.2K bytes - Viewed (0) -
operator/cmd/mesh/manifest-diff.go
// selectResources constrains the list of resources to compare to only the ones in this list, ignoring all others. // The format of each list item is :: and the items are comma separated. The * character represents wildcard selection. // e.g. // Deployment:istio-system:* - compare all deployments in istio-system namespace // Service:*:istio-pilot - compare Services called "istio-pilot" in all namespaces. selectResources string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/bucket/replication/sourceselectioncriteria.go
) // ReplicaModifications specifies if replica modification sync is enabled type ReplicaModifications struct { Status Status `xml:"Status" json:"Status"` } // SourceSelectionCriteria - specifies additional source selection criteria in ReplicationConfiguration. type SourceSelectionCriteria struct { ReplicaModifications ReplicaModifications `xml:"ReplicaModifications" json:"ReplicaModifications"` }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.5K bytes - Viewed (0) -
cmd/postpolicyform.go
reader, err := sanitizePolicy(r) if err != nil { return PostPolicyForm{}, err } d := json.NewDecoder(reader) // Convert po into interfaces and // perform strict type conversion using reflection. var rawPolicy struct { Expiration string `json:"expiration"` Conditions []interface{} `json:"conditions"` } d.DisallowUnknownFields() if err := d.Decode(&rawPolicy); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.2K bytes - Viewed (0) -
internal/s3select/select.go
if s3Select.progressReader != nil { return s3Select.progressReader.Stats() } return -1, -1 } // Open - opens S3 object by using callback for SQL selection query. // Currently CSV, JSON and Apache Parquet formats are supported. func (s3Select *S3Select) Open(rsc io.ReadSeekCloser) error { offset, length, err := s3Select.ScanRange.StartLen() if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
if hpaName := mustGetPath(t, hpaRev, "spec.scaleTargetRef.name"); nameRev != hpaName { t.Fatalf("HPA does not match deployment: %v != %v", nameRev, hpaName) } // Check selection of previous versions . This only matters for in place upgrade (non revision) podLabels15 := map[string]string{ "app": "istiod", "istio": "pilot", }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0)