- Sort Score
- Result 10 results
- Languages All
Results 891 - 900 of 1,384 for funcs (0.04 sec)
-
misc/ios/go_ios_exec.go
return 1, err } err = runOnSimulator(appdir) if err != nil { return 1, err } return 0, nil } func runOnSimulator(appdir string) error { if err := installSimulator(appdir); err != nil { return err } return runSimulator(appdir, bundleID, os.Args[2:]) } func assembleApp(appdir, bin string) error { if err := os.MkdirAll(appdir, 0755); err != nil { return err }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Jun 18 16:32:49 UTC 2024 - 8.7K bytes - Viewed (0) -
docs/sts/web-identity.go
return } var getWebTokenExpiry func() (*credentials.WebIdentityToken, error) if clientSec == "" { getWebTokenExpiry = func() (*credentials.WebIdentityToken, error) { return &credentials.WebIdentityToken{ Token: r.Form.Get("id_token"), }, nil } } else { getWebTokenExpiry = func() (*credentials.WebIdentityToken, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 19 09:13:33 UTC 2023 - 7.8K bytes - Viewed (0) -
cmd/metrics-v3-api.go
) // loadAPIRequestsHTTPMetrics - reads S3 HTTP metrics. // // This is a `MetricsLoaderFn`. // // This includes node level S3 HTTP metrics. // // This function currently ignores `opts`. func loadAPIRequestsHTTPMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error { // Collect node level S3 HTTP metrics. httpStats := globalHTTPStats.toServerHTTPStats(false)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 9.4K bytes - Viewed (0) -
internal/event/target/kafka_scram_client_contrib.go
"strings" "github.com/IBM/sarama" "github.com/xdg/scram" "github.com/minio/minio/internal/hash/sha256" ) func initScramClient(args KafkaArgs, config *sarama.Config) { switch strings.ToLower(args.SASL.Mechanism) { case "sha512": config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: KafkaSHA512} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Nov 09 04:04:01 UTC 2023 - 3.2K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
"Average time for write requests served on a drive", allDriveLabels...) drivePercUtilMD = NewGaugeMD(drivePercUtil, "Percentage of time the disk was busy", allDriveLabels...) ) func getCurrentDriveIOStats() map[string]madmin.DiskIOStats { var types madmin.MetricType = madmin.MetricsDisk driveRealtimeMetrics := collectLocalMetrics(types, collectMetricsOpts{ hosts: map[string]struct{}{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun May 12 17:23:50 UTC 2024 - 7.9K bytes - Viewed (0) -
cmd/xl-storage_test.go
} for _, testCase := range testCases { gotErr := checkPathLength(testCase.path) t.Run("", func(t *testing.T) { if gotErr != testCase.expectedErr { t.Errorf("Expected %s, got %s", testCase.expectedErr, gotErr) } }) } } // Tests validate volume name. func TestIsValidVolname(t *testing.T) { testCases := []struct { volName string shouldPass bool }{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 66.7K bytes - Viewed (0) -
cmd/shared-lock.go
break keepLock case ld.lockContext <- lkctx: // Send the lock context to anyone asking for it } } } } func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) { ctx, cancel := context.WithCancel(context.Background()) go func() { select { case <-ctx1.Done(): case <-ctx2.Done(): // The lock acquirer decides to cancel, exit this goroutine case <-ctx.Done(): }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
cmd/admin-handlers-users.go
// ImportIAM - imports all IAM info into MinIO func (a adminAPIHandlers) ImportIAM(w http.ResponseWriter, r *http.Request) { a.importIAM(w, r, "") } // ImportIAMV2 - imports all IAM info into MinIO func (a adminAPIHandlers) ImportIAMV2(w http.ResponseWriter, r *http.Request) { a.importIAM(w, r, "v2") } // ImportIAM - imports all IAM info into MinIO
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 03 23:11:02 UTC 2024 - 85.1K bytes - Viewed (0) -
internal/event/target/postgresql_test.go
// TestPostgreSQLRegistration checks if postgres driver // is registered and fails otherwise. func TestPostgreSQLRegistration(t *testing.T) { var found bool for _, drv := range sql.Drivers() { if drv == "postgres" { found = true break } } if !found { t.Fatal("postgres driver not registered") } } func TestPsqlTableNameValidation(t *testing.T) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Apr 24 17:51:07 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/amztime/parse_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. // Package amztime implements AWS specific time parsing and deviations package amztime import ( "errors" "testing" "time" ) func TestParse(t *testing.T) { type testCase struct { expectedErr error expectedTime time.Time timeStr string } testCases := []testCase{ { ErrMalformedDate, time.Time{},
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 07 14:24:54 UTC 2022 - 1.6K bytes - Viewed (0)