- Sort Score
- Result 10 results
- Languages All
Results 1141 - 1150 of 1,384 for funcs (0.03 sec)
-
istioctl/pkg/tag/revision.go
} return revisions, nil } func Webhooks(ctx context.Context, client kube.CLIClient) ([]admitv1.MutatingWebhookConfiguration, error) { hooks, err := client.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().List(ctx, metav1.ListOptions{}) if err != nil { return []admitv1.MutatingWebhookConfiguration{}, err } return hooks.Items, nil } func renderWithDefault(s, def string) string { if s != "" {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/metacache-set_gen.go
package cmd // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *listPathOptions) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 19 20:23:12 UTC 2024 - 13.8K bytes - Viewed (0) -
cmd/signature-v4-parser_test.go
"strings" "testing" "time" ) // generates credential string from its fields. func generateCredentialStr(accessKey, date, region, service, requestVersion string) string { return "Credential=" + joinWithSlash(accessKey, date, region, service, requestVersion) } // joins the argument strings with a '/' and returns it. func joinWithSlash(accessKey, date, region, service, requestVersion string) string { return strings.Join([]string{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 27.4K bytes - Viewed (0) -
cmd/sts-errors.go
package cmd import ( "context" "encoding/xml" "net/http" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/logger" ) // writeSTSErrorResponse writes error headers func writeSTSErrorResponse(ctx context.Context, w http.ResponseWriter, errCode STSErrorCode, err error) { stsErr := stsErrCodes.ToSTSErr(errCode) // Generate error response. stsErrorResponse := STSErrorResponse{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 5.8K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
) // GetBucketNotificationHandler - This HTTP handler returns event notification configuration // as per http://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html. // It returns empty configuration if its not set. func (api objectAPIHandlers) GetBucketNotificationHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "GetBucketNotification") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.1K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
func testListObjectsOnVersionedBuckets(obj ObjectLayer, instanceType string, t1 TestErrHandler) { _testListObjects(obj, instanceType, t1, true) } // Unit test for ListObjects. func testListObjects(obj ObjectLayer, instanceType string, t1 TestErrHandler) { _testListObjects(obj, instanceType, t1, false) } func _testListObjects(obj ObjectLayer, instanceType string, t1 TestErrHandler, versioned bool) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 01 11:07:40 UTC 2024 - 73.1K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
maxBucketVersioningConfigSize = 1 * humanize.MiByte ) // PutBucketVersioningHandler - PUT Bucket Versioning. // ---------- func (api objectAPIHandlers) PutBucketVersioningHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "PutBucketVersioning") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) vars := mux.Vars(r)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5K bytes - Viewed (0) -
tests/scan_test.go
"sort" "strings" "testing" "time" "gorm.io/gorm" . "gorm.io/gorm/utils/tests" ) type PersonAddressInfo struct { Person *Person `gorm:"embedded"` Address *Address `gorm:"embedded"` } func TestScan(t *testing.T) { user1 := User{Name: "ScanUser1", Age: 1} user2 := User{Name: "ScanUser2", Age: 10} user3 := User{Name: "ScanUser3", Age: 20} DB.Save(&user1).Save(&user2).Save(&user3) type result struct {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 10:57:36 UTC 2024 - 10.9K bytes - Viewed (0) -
internal/config/lambda/event/arn.go
TargetID region string } // String - returns string representation. func (arn ARN) String() string { if arn.TargetID.ID == "" && arn.TargetID.Name == "" && arn.region == "" { return "" } return "arn:minio:s3-object-lambda:" + arn.region + ":" + arn.TargetID.String() } // ParseARN - parses string to ARN. func ParseARN(s string) (*ARN, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 1.6K bytes - Viewed (0) -
cmd/metrics-v3-cluster-erasure-set.go
"Health of the erasure set in a pool for write operations (1=healthy, 0=unhealthy)", poolIDL, setIDL) ) func b2f(v bool) float64 { if v { return 1 } return 0 } // loadClusterErasureSetMetrics - `MetricsLoaderFn` for cluster storage erasure // set metrics. func loadClusterErasureSetMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { result, _ := c.esetHealthResult.Get()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 14 07:25:56 UTC 2024 - 4.4K bytes - Viewed (0)