- Sort Score
- Result 10 results
- Languages All
Results 231 - 240 of 1,214 for Func (0.06 sec)
-
src/archive/tar/writer_test.go
} // failOnceWriter fails exactly once and then always reports success. type failOnceWriter bool func (w *failOnceWriter) Write(b []byte) (int, error) { if !*w { return 0, io.ErrShortWrite } *w = true return len(b), nil } func TestWriterErrors(t *testing.T) { t.Run("HeaderOnly", func(t *testing.T) { tw := NewWriter(new(bytes.Buffer)) hdr := &Header{Name: "dir/", Typeflag: TypeDir}
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Sep 23 14:32:33 UTC 2024 - 39.4K bytes - Viewed (0) -
src/cmd/api/testdata/src/pkg/p2/golden.txt
pkg p2, func F() string pkg p2, func F //deprecated pkg p2, func G() Twoer pkg p2, func NewError(string) error pkg p2, type Twoer interface { PackageTwoMeth } pkg p2, type Twoer interface, PackageTwoMeth()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Dec 02 16:29:41 UTC 2022 - 265 bytes - Viewed (0) -
soft_delete.go
} type SoftDeleteQueryClause struct { ZeroValue sql.NullString Field *schema.Field } func (sd SoftDeleteQueryClause) Name() string { return "" } func (sd SoftDeleteQueryClause) Build(clause.Builder) { } func (sd SoftDeleteQueryClause) MergeClause(*clause.Clause) { } func (sd SoftDeleteQueryClause) ModifyStatement(stmt *Statement) {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Feb 01 06:40:55 UTC 2023 - 4.5K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgActiveWorkerStat(b *testing.B) { v := ActiveWorkerStat{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgActiveWorkerStat(b *testing.B) { v := ActiveWorkerStat{} bts := make([]byte, 0, v.Msgsize())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 17.4K bytes - Viewed (0) -
cmd/notification.go
// returns the slice of errors from all function calls. func (g *NotificationGroup) Wait() []NotificationPeerErr { g.workers.Wait() return g.errs } // Go calls the given function in a new goroutine. // // The first call to return a non-nil error will be // collected in errs slice and returned by Wait(). func (g *NotificationGroup) Go(ctx context.Context, f func() error, index int, addr xnet.Host) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
func (c *DeadlineConn) WithReadDeadline(d time.Duration) *DeadlineConn { c.readDeadline = d return c } // WithWriteDeadline sets a new write side net.Conn deadline. func (c *DeadlineConn) WithWriteDeadline(d time.Duration) *DeadlineConn { c.writeDeadline = d return c } // New - creates a new connection object wrapping net.Conn with deadlines. func New(c net.Conn) *DeadlineConn {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 17:40:11 UTC 2024 - 2.6K bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
fillReady chan int64 readerErr error // underlying reader error, if any } func newScanner(r io.Reader) *scanner { sr := &scanner{ end: maxInt, fillReq: make(chan struct{}), fillReady: make(chan int64), } go func() { var rpos int64 // total bytes read into buffer defer func() { atomic.StoreInt64(&sr.end, rpos) close(sr.fillReady) }() for range sr.fillReq {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0) -
internal/event/rulesmap.go
func (rulesMap RulesMap) add(eventNames []Name, pattern string, targetID TargetID) { rules := make(Rules) rules.Add(pattern, targetID) for _, eventName := range eventNames { for _, name := range eventName.Expand() { rulesMap[name] = rulesMap[name].Union(rules) } } } // Clone - returns copy of this rules map. func (rulesMap RulesMap) Clone() RulesMap {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 2.6K bytes - Viewed (0) -
internal/ioutil/wait_pipe.go
*io.PipeWriter once sync.Once done func() } // CloseWithError close with supplied error the writer end. func (w *PipeWriter) CloseWithError(err error) error { err = w.PipeWriter.CloseWithError(err) w.once.Do(func() { w.done() }) return err } // PipeReader is similar to io.PipeReader with wait group type PipeReader struct { *io.PipeReader wait func() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 27 14:55:36 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen_test.go
} if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBucketReplicationResyncStatus(b *testing.B) { v := BucketReplicationResyncStatus{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgBucketReplicationResyncStatus(b *testing.B) { v := BucketReplicationResyncStatus{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 22 23:53:06 UTC 2022 - 23K bytes - Viewed (0)