- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 1,387 for funcs (0.03 sec)
-
internal/hash/reader.go
// not the actual SHA256 checksum of the content. func (r *Reader) SHA256() []byte { return r.contentSHA256 } // SHA256HexString returns a hex representation of the SHA256. func (r *Reader) SHA256HexString() string { return hex.EncodeToString(r.contentSHA256) } // ContentCRCType returns the content checksum type. func (r *Reader) ContentCRCType() ChecksumType { return r.contentHash.Type }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 19 12:59:07 UTC 2024 - 10.9K bytes - Viewed (0) -
internal/cachevalue/cache_test.go
"errors" "testing" "time" ) func slowCaller(ctx context.Context) error { sl := time.NewTimer(time.Second) defer sl.Stop() select { case <-sl.C: case <-ctx.Done(): return ctx.Err() } return nil } func TestCacheCtx(t *testing.T) { cache := New[time.Time]() t.Parallel() cache.InitOnce(2*time.Second, Opts{}, func(ctx context.Context) (time.Time, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 2.7K bytes - Viewed (0) -
internal/store/batch.go
func (b *Batch[I]) Close() error { defer func() { close(b.quitCh) }() b.Lock() defer b.Unlock() return b.commit() } // NewBatch creates a new batch func NewBatch[I any](config BatchConfig[I]) *Batch[I] { if config.CommitTimeout == 0 { config.CommitTimeout = defaultCommitTimeout } quitCh := make(chan struct{}) batch := &Batch[I]{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 2.9K bytes - Viewed (0) -
misc/ios/detect.go
matches++ } } } if matches == len(udids) { files = append(files, string(line)) } } return files } func parseMobileProvision(fname string) *exec.Cmd { return exec.Command("security", "cms", "-D", "-i", string(fname)) } func plistExtract(fname string, path string) ([]byte, error) { out, err := exec.Command("/usr/libexec/PlistBuddy", "-c", "Print "+path, fname).CombinedOutput()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Oct 19 23:33:30 UTC 2023 - 3.2K bytes - Viewed (0) -
src/bufio/example_test.go
package bufio_test import ( "bufio" "bytes" "fmt" "os" "strconv" "strings" ) func ExampleWriter() { w := bufio.NewWriter(os.Stdout) fmt.Fprint(w, "Hello, ") fmt.Fprint(w, "world!") w.Flush() // Don't forget to flush! // Output: Hello, world! } func ExampleWriter_AvailableBuffer() { w := bufio.NewWriter(os.Stdout) for _, i := range []int64{1, 2, 3, 4} {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Nov 01 21:52:12 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/bucket/replication/destination.go
} func (d Destination) isValidStorageClass() bool { if d.StorageClass == "" { return true } return d.StorageClass == "STANDARD" || d.StorageClass == "REDUCED_REDUNDANCY" } // IsValid - checks whether Destination is valid or not. func (d Destination) IsValid() bool { return d.Bucket != "" || !d.isValidStorageClass() } func (d Destination) String() string { return d.ARN }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4K bytes - Viewed (0) -
cni/pkg/iptables/iptables_linux.go
"istio.io/istio/pkg/ptr" ) func AddInpodMarkIPRule(cfg *Config) error { err := forEachInpodMarkIPRule(cfg, netlink.RuleAdd) if errors.Is(err, unix.EEXIST) { log.Debugf("Ignoring exists error adding inpod mark ip rule: %v", err) return nil } return err } func DelInpodMarkIPRule(cfg *Config) error { return forEachInpodMarkIPRule(cfg, netlink.RuleDel) }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Sep 06 09:44:28 UTC 2024 - 4K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen.go
package cmd // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *DailyAllTierStats) DecodeMsg(dc *msgp.Reader) (err error) { var zb0004 uint32 zb0004, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } if (*z) == nil { (*z) = make(DailyAllTierStats, zb0004) } else if len((*z)) > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 9.3K bytes - Viewed (0) -
internal/s3select/sql/statement.go
} // IsAggregated returns if the statement involves SQL aggregation func (e *SelectStatement) IsAggregated() bool { return e.selectQProp.isAggregation } // AggregateResult - returns the aggregated result after all input // records have been processed. Applies only to aggregation queries. func (e *SelectStatement) AggregateResult(output Record) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 8.9K bytes - Viewed (0) -
internal/dsync/drwmutex.go
type Granted struct { index int lockUID string // Locked if set with UID string, unlocked if empty } func (g *Granted) isLocked() bool { return isLocked(g.lockUID) } func isLocked(uid string) bool { return len(uid) > 0 } // NewDRWMutex - initializes a new dsync RW mutex. func NewDRWMutex(clnt *Dsync, names ...string) *DRWMutex { restClnts, _ := clnt.GetLockers() sort.Strings(names)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0)