- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Reimplement (0.18 sec)
-
internal/http/dial_dnscache.go
// DialContextWithLookupHost is a helper function which returns `net.DialContext` function. // It randomly fetches an IP via custom LookupHost function and dials it by the given dial // function. LookupHost may implement an internal DNS caching implementation, lookupHost // input if nil then net.DefaultResolver.LookupHost is used. // // It dials one by one and returns first connected `net.Conn`.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 03 19:30:51 GMT 2023 - 2.6K bytes - Viewed (0) -
internal/config/help.go
// exposed by the server Secret bool `json:"-"` // Indicates if sub-sys supports multiple targets. MultipleTargets bool `json:"multipleTargets"` } // HelpKVS - implement order of keys help messages. type HelpKVS []HelpKV // Lookup - lookup a key from help kvs. func (hkvs HelpKVS) Lookup(key string) (HelpKV, bool) { for _, hkv := range hkvs { if hkv.Key == key {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 23 14:45:27 GMT 2023 - 2.8K bytes - Viewed (0) -
src/bufio/example_test.go
fmt.Println(len(scanner.Bytes()) == 6) } if err := scanner.Err(); err != nil { fmt.Fprintln(os.Stderr, "shouldn't see an error scanning a string") } // Output: // true } // Use a Scanner to implement a simple word-count utility by scanning the // input as a sequence of space-delimited tokens. func ExampleScanner_words() { // An artificial input source.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 4.9K bytes - Viewed (0) -
internal/hash/reader.go
// DecompressedSize - For compressed objects. func (r *Reader) ActualSize() int64 { return r.actualSize } // ETag returns the ETag computed by an underlying etag.Tagger. // If the underlying io.Reader does not implement etag.Tagger // it returns nil. func (r *Reader) ETag() etag.ETag { if t, ok := r.src.(etag.Tagger); ok { return t.ETag() } return nil } // MD5Current returns the MD5 checksum of the content
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
cmd/batch-expire.go
results := make(chan ObjectInfo, workerSize) if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{ Marker: lastObject, LatestOnly: false, // we need to visit all versions of the object to implement purge: retainVersions VersionsSort: WalkVersionsSortDesc, }); err != nil { // Do not need to retry if we can't list objects on source. return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
src/archive/tar/stat_unix.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 3.2K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
prog.From = a[0] if a[1].Type == obj.TYPE_REG { prog.Reg = p.getRegister(prog, op, &a[1]) } else { prog.AddRestSource(a[1]) } prog.To = a[2] default: p.errorf("TODO: implement three-operand instructions for this architecture") return } case 4: if p.arch.Family == sys.ARM { if arch.IsARMBFX(op) { // a[0] and a[1] must be constants, a[2] and a[3] must be registers
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 25.3K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics_test.go
if !ok { return prometheus_model.Vector{}, nil, nil } return canned, nil, nil } func (client mockPromAPI) WalReplay(ctx context.Context) (promv1.WalReplayStatus, error) { // TODO implement me panic("implement me") } func (client mockPromAPI) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time, ) ([]prometheus_model.LabelSet, promv1.Warnings, error) { return nil, nil, nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 25 02:07:44 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/s3select/select.go
rsc.reader = nil } return rsc.offset, nil } // Read call to implement io.Reader func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) { if rsc.reader == nil { rsc.reader, err = rsc.segmentReader(rsc.offset) if err != nil { return 0, err } } return rsc.reader.Read(p) } // Close call to implement io.Closer. Calling Read/Seek after Close reopens the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (1) -
logger/logger.go
RowsAffected int64 Err error } // New trace recorder func (l *traceRecorder) New() *traceRecorder { return &traceRecorder{Interface: l.Interface, BeginAt: time.Now()} } // Trace implement logger interface func (l *traceRecorder) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error) { l.BeginAt = begin l.SQL, l.RowsAffected = fc() l.Err = err
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Nov 07 02:19:41 GMT 2023 - 5.8K bytes - Viewed (0)