- Sort Score
- Result 10 results
- Languages All
Results 471 - 480 of 1,387 for funcs (0.02 sec)
-
istioctl/pkg/multixds/gather.go
} return &retval, nil } func makeSan(istioNamespace, revision string) string { if revision == "" { return fmt.Sprintf("istiod.%s.svc", istioNamespace) } return fmt.Sprintf("istiod-%s.%s.svc", revision, istioNamespace) } // AllRequestAndProcessXds returns all XDS responses from 1 central or 1..N K8s cluster-based XDS servers // nolint: lll
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/bitrot-whole.go
hash.Hash // For bitrot hash } func (b *wholeBitrotWriter) Write(p []byte) (int, error) { err := b.disk.AppendFile(context.TODO(), b.volume, b.filePath, p) if err != nil { return 0, err } _, err = b.Hash.Write(p) if err != nil { return 0, err } return len(p), nil } func (b *wholeBitrotWriter) Close() error { return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 2.7K bytes - Viewed (0) -
cmd/etcd.go
func etcdErrToErr(err error, etcdEndpoints []string) error { if err == nil { return nil } switch err { case context.DeadlineExceeded: return fmt.Errorf("%w %s", errEtcdUnreachable, etcdEndpoints) default: return fmt.Errorf("unexpected error %w from etcd, please check your endpoints %s", err, etcdEndpoints) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/lock/lock.go
*LockedFile mutex sync.Mutex refs int // Holds read lock refs. } // IsClosed - Check if the rlocked file is already closed. func (r *RLockedFile) IsClosed() bool { r.mutex.Lock() defer r.mutex.Unlock() return r.refs == 0 } // IncLockRef - is used by called to indicate lock refs. func (r *RLockedFile) IncLockRef() { r.mutex.Lock() r.refs++ r.mutex.Unlock() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 2.5K bytes - Viewed (0) -
clause/returning.go
package clause type Returning struct { Columns []Column } // Name where clause name func (returning Returning) Name() string { return "RETURNING" } // Build build where clause func (returning Returning) Build(builder Builder) { if len(returning.Columns) > 0 { for idx, column := range returning.Columns { if idx > 0 { builder.WriteByte(',') } builder.WriteQuoted(column) } } else {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Oct 27 23:56:55 UTC 2021 - 681 bytes - Viewed (0) -
cmd/os-readdir_test.go
dir string entries []string } // Test to read empty directory. func setupTestReadDirEmpty(t *testing.T) (testResults []result) { // Add empty entry slice for this test directory. testResults = append(testResults, result{t.TempDir(), []string{}}) return testResults } // Test to read non-empty directory with only files. func setupTestReadDirFiles(t *testing.T) (testResults []result) { dir := t.TempDir()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 7.5K bytes - Viewed (0) -
cmd/postpolicyform.go
) // toString - Safely convert interface to string without causing panic. func toString(val interface{}) string { switch v := val.(type) { case string: return v default: return "" } } // toLowerString - safely convert interface to lower string func toLowerString(val interface{}) string { return strings.ToLower(toString(val)) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 12.4K bytes - Viewed (0) -
cmd/signature-v4.go
// getScope generate a string of a specific date, an AWS region, and a service. func getScope(t time.Time, region string) string { scope := strings.Join([]string{ t.Format(yyyymmdd), region, string(serviceS3), "aws4_request", }, SlashSeparator) return scope } // getStringToSign a string based on selected query values. func getStringToSign(canonicalRequest string, t time.Time, scope string) string {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 12.4K bytes - Viewed (0) -
internal/config/notify/legacy.go
import ( "fmt" "strconv" "strings" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/event/target" ) // SetNotifyKafka - helper for config migration from older config. func SetNotifyKafka(s config.Config, name string, cfg target.KafkaArgs) error { if !cfg.Enable { return nil } if err := cfg.Validate(); err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 19 04:37:54 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/jwt.go
} groups = ucred.Groups } return claims, groups, owner, nil } // newCachedAuthToken returns the cached token. func newCachedAuthToken() func() string { return func() string { return globalNodeAuthToken }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 4.5K bytes - Viewed (0)