- Sort Score
- Result 10 results
- Languages All
Results 881 - 890 of 1,405 for rfunc (0.02 sec)
-
cmd/object-handlers-common_test.go
package cmd import ( "bytes" "context" "net/http" "net/http/httptest" "testing" "time" xhttp "github.com/minio/minio/internal/http" ) // Tests - canonicalizeETag() func TestCanonicalizeETag(t *testing.T) { testCases := []struct { etag string canonicalizedETag string }{ { etag: "\"\"\"", canonicalizedETag: "", }, {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 06:33:53 UTC 2024 - 5.3K 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) -
clause/clause.go
package clause // Interface clause interface type Interface interface { Name() string Build(Builder) MergeClause(*Clause) } // ClauseBuilder clause builder, allows to customize how to build clause type ClauseBuilder func(Clause, Builder) type Writer interface { WriteByte(byte) error WriteString(string) (int, error) } // Builder builder interface type Builder interface { Writer WriteQuoted(field interface{})
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Feb 02 09:15:08 UTC 2023 - 1.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) -
internal/config/dns/dns_path.go
// the root label it is ignored. Not other syntax checks are performed. func dnsJoin(labels ...string) string { ll := len(labels) if labels[ll-1] == "." { return strings.Join(labels[:ll-1], ".") + "." } return dns.Fqdn(strings.Join(labels, ".")) } // msgUnPath converts a etcd path to domainName. func msgUnPath(s string) string { l := strings.Split(s, etcdPathSeparator) if l[len(l)-1] == "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 15:03:08 UTC 2024 - 1.9K bytes - Viewed (0) -
misc/go_android_exec/exitcode_test.go
t.Errorf("want output %q, got %q", want, got) } if want := 1; want != code { t.Errorf("want exit code %d, got %d", want, code) } } func TestExitCodeMissing(t *testing.T) { var wantErr *regexp.Regexp check := func(text string) { t.Helper() var out strings.Builder f, exitStr := newExitCodeFilter(&out) if want := "exitcode="; want != exitStr {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed May 03 14:54:58 UTC 2023 - 2.1K bytes - Viewed (0) -
lib/time/mkzip.go
package main import ( "archive/zip" "bytes" "flag" "fmt" "hash/crc32" "io/fs" "log" "os" "path/filepath" "strings" ) func usage() { fmt.Fprintf(os.Stderr, "usage: go run mkzip.go zoneinfo.zip\n") os.Exit(2) } func main() { log.SetPrefix("mkzip: ") log.SetFlags(0) flag.Usage = usage flag.Parse() args := flag.Args()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Mar 04 17:32:07 UTC 2024 - 2.1K bytes - Viewed (0) -
istioctl/cmd/root_test.go
"github.com/spf13/cobra" ) func checkHelpForFlag(t *testing.T, gotHelpText, flag string, wantExists bool) { t.Helper() if strings.Contains(gotHelpText, flag) != wantExists { if wantExists { t.Errorf("%q flag was expected but not found in help text", flag) } else { t.Errorf("%q flag was found in help text but not expected", flag) } } } func TestHideInheritedFlags(t *testing.T) { const (
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jan 15 17:59:55 UTC 2021 - 2.4K bytes - Viewed (0) -
cmd/xl-storage_unix_test.go
"syscall" "testing" ) // Based on `man getumask` a vaporware GNU extension to glibc. // returns file mode creation mask. func getUmask() int { mask := syscall.Umask(0) syscall.Umask(mask) return mask } // Tests if the directory and file creations happen with proper umask. func TestIsValidUmaskVol(t *testing.T) { tmpPath := t.TempDir() testCases := []struct { volName string expectedUmask int }{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 25 19:37:26 UTC 2022 - 3.4K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard_test.go
Namespace: "istio-system", })) for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.Args, " ")), func(t *testing.T) { testutil.VerifyOutput(t, dbCmd, c) cleanupTestCase() }) } } func cleanupTestCase() { labelSelector = ""
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Nov 21 01:17:24 UTC 2023 - 4.3K bytes - Viewed (0)