- Sort Score
- Result 10 results
- Languages All
Results 461 - 470 of 1,425 for Func (0.08 sec)
-
istioctl/pkg/writer/table/writer_test.go
namespace string version string } var newTestObject = func(name, namespace, version string) testObject { return testObject{ name: name, namespace: namespace, version: version, } } func TestWriter(t *testing.T) { got := &bytes.Buffer{} w := NewStyleWriter(got) w.AddHeader("NAME", "NAMESPACE", "VERSION") w.SetAddRowFunc(func(obj interface{}) Row { o := obj.(testObject) return Row{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Oct 08 04:41:42 UTC 2022 - 1.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/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) -
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/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) -
clause/locking.go
LockingOptionsNoWait = "NOWAIT" ) type Locking struct { Strength string Table Table Options string } // Name where clause name func (locking Locking) Name() string { return "FOR" } // Build build where clause func (locking Locking) Build(builder Builder) { builder.WriteString(locking.Strength) if locking.Table.Name != "" { builder.WriteString(" OF ")
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Fri Dec 15 08:32:56 UTC 2023 - 773 bytes - Viewed (0) -
tests/prepared_stmt_test.go
if err := tx.Find(&result3, user2.ID).Error; err != nil { t.Fatalf("no error should happen but got %v", err) } } func TestPreparedStmtFromTransaction(t *testing.T) { db := DB.Session(&gorm.Session{PrepareStmt: true, SkipDefaultTransaction: true}) tx := db.Begin() defer func() { if r := recover(); r != nil { tx.Rollback() } }() if err := tx.Error; err != nil {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:02:05 UTC 2024 - 8.5K bytes - Viewed (0)