- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 40 for souring (0.19 sec)
-
cmd/metacache-stream.go
// Returns the first error the occurred during the writing if any. func (w *metacacheBlockWriter) Close() error { w.wg.Wait() return w.streamErr } type metacacheBlock struct { data []byte n int First string `json:"f"` Last string `json:"l"` EOS bool `json:"eos,omitempty"` } func (b metacacheBlock) headerKV() map[string]string { json := jsoniter.ConfigCompatibleWithStandardLibrary
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
testCases := []struct { inputConfig string objectName string objectTags string objectModTime time.Time isDelMarker bool hasManyVersions bool expectedAction Action isNoncurrent bool objectSuccessorModTime time.Time versionID string }{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 53.2K bytes - Viewed (0) -
src/cmd/api/main_test.go
if err != nil { log.Fatalf("loading imports: %v\n%s", err, out) } var stdPackages []string importMap := make(map[string]map[string]string) importDir := make(map[string]string) dec := json.NewDecoder(bytes.NewReader(out)) for { var pkg struct { ImportPath, Dir string ImportMap map[string]string Standard bool } err := dec.Decode(&pkg) if err == io.EOF { break
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
src/archive/tar/common.go
func (h Header) allowedFormats() (format Format, paxHdrs map[string]string, err error) { format = FormatUSTAR | FormatPAX | FormatGNU paxHdrs = make(map[string]string) var whyNoUSTAR, whyNoPAX, whyNoGNU string var preferPAX bool // Prefer PAX over USTAR verifyString := func(s string, size int, name, paxKey string) { // NUL-terminator is optional for path and linkpath.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24.7K bytes - Viewed (2) -
cmd/erasure-healing.go
} if result.After.Drives != nil { opts.Tags = map[string]interface{}{"drives-result": result.After.Drives} } auditLogInternal(ctx, opts) } // Heals an object by re-writing corrupt/missing erasure blocks. func (er *erasureObjects) healObject(ctx context.Context, bucket string, object string, versionID string, opts madmin.HealOpts) (result madmin.HealResultItem, err error) { dryRun := opts.DryRun
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/erasure-sets.go
return func() ([]dsync.NetLocker, string) { lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex])) copy(lockers, s.erasureLockers[setIndex]) return lockers, s.erasureLockOwner } } func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string { return func() []string { eps := make([]string, s.setDriveCount)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/object-handlers_test.go
{"small-1", []int64{509}, make(map[string]string)}, {"small-2", []int64{5 * oneMiB}, make(map[string]string)}, // // // cases 5-8: multipart part objects {"mp-0", []int64{5 * oneMiB, 1}, make(map[string]string)}, {"mp-1", []int64{5*oneMiB + 1, 1}, make(map[string]string)}, {"mp-2", []int64{5487701, 5487799, 3}, make(map[string]string)}, {"mp-3", []int64{10499807, 10499963, 7}, make(map[string]string)},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
cni/pkg/iptables/iptables_linux.go
} // Set up netlink routes for localhost cidrs := []string{"0.0.0.0/0"} if cfg.EnableIPv6 { cidrs = append(cidrs, "0::0/0") } for _, fullCIDR := range cidrs { _, localhostDst, err := net.ParseCIDR(fullCIDR) if err != nil { return fmt.Errorf("parse CIDR: %v", err) } netlinkRoutes := []*netlink.Route{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.3K bytes - Viewed (0) -
internal/config/notify/help.go
Optional: true, Type: "string", }, config.HelpKV{ Key: target.AmqpExchangeType, Description: "AMQP exchange type", Optional: true, Type: "string", }, config.HelpKV{ Key: target.AmqpRoutingKey, Description: "routing key for publishing", Optional: true, Type: "string", Sensitive: true, }, config.HelpKV{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
} fi.Metadata = make(map[string]string, len(j.MetaSys)) for k, v := range j.MetaSys { fi.Metadata[k] = string(v) } fi.ReplicationState = GetInternalReplicationState(j.MetaSys) if j.FreeVersion() { fi.SetTierFreeVersion() fi.TransitionTier = string(j.MetaSys[metaTierName]) fi.TransitionedObjName = string(j.MetaSys[metaTierObjName]) fi.TransitionVersionID = string(j.MetaSys[metaTierVersionID]) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 05:07:37 GMT 2024 - 63.6K bytes - Viewed (1)