- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for Petry (0.18 sec)
-
cmd/batch-expire_gen.go
} case "NotificationCfg": err = z.NotificationCfg.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "NotificationCfg") return } case "Retry": err = z.Retry.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Retry") return } case "Rules": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "Rules") return
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 19.8K bytes - Viewed (0) -
cmd/batch-replicate.go
// - filter // - notify // - retry type BatchJobReplicateFlags struct { Filter BatchReplicateFilter `yaml:"filter" json:"filter"` Notify BatchJobNotification `yaml:"notify" json:"notify"` Retry BatchJobRetry `yaml:"retry" json:"retry"` } // BatchJobReplicateResourceType defines the type of batch jobs type BatchJobReplicateResourceType string
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Nov 22 18:51:46 GMT 2023 - 6.3K bytes - Viewed (0) -
cmd/batch-handlers.go
ri.RetryAttempts = batchReplJobDefaultRetries if job.Replicate.Flags.Retry.Attempts > 0 { ri.RetryAttempts = job.Replicate.Flags.Retry.Attempts } case job.KeyRotate != nil: ri.RetryAttempts = batchKeyRotateJobDefaultRetries if job.KeyRotate.Flags.Retry.Attempts > 0 { ri.RetryAttempts = job.KeyRotate.Flags.Retry.Attempts } case job.Expire != nil:
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil { panic("expected snapshot sent") } sendAck(ztunClient) ztunClient.Close() // this will retry for a bit, so shouldn't flake mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(0)) } func TestZtunnelRemovePod(t *testing.T) { ztunnelKeepAliveCheckInterval = time.Second / 10 mt := monitortest.New(t)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cmd/data-usage-cache.go
} // Caches are read+written without locks, retries := 0 for retries < 5 { retry, err := load(name, time.Minute) if err != nil { return toObjectErr(err, dataUsageBucket, name) } if !retry { break } retry, err = load(name+".bkp", 30*time.Second) if err == nil && !retry { // Only return when we have valid data from the backup break } retries++
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
internal/dsync/drwmutex.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
return err } func runDevice(appdir, bundleID string, args []string) error { attempt := 0 for { // The device app path reported by the device might be stale, so retry // the lookup of the device path along with the lldb launching below. deviceapp, err := findDeviceAppPath(bundleID) if err != nil { // The device app path might not yet exist for a newly installed app.
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
cmd/metacache-set.go
if err != nil { switch toObjectErr(err, minioMetaBucket, o.objectPath(0)).(type) { case ObjectNotFound, InsufficientReadQuorum: retryWait() continue } // Allow one fast retry for other errors. if retries > 0 { return entries, fmt.Errorf("reading first part metadata: %v", err) } retryWait() continue } partN, err := o.findFirstPart(fi) switch {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/notification.go
if nerrs <= 0 { nerrs = 1 } wk, _ := workers.New(wks) return &NotificationGroup{errs: make([]NotificationPeerErr, nerrs), workers: wk, retryCount: 3} } // WithRetries sets the retry count for all function calls from the Go method. func (g *NotificationGroup) WithRetries(retryCount int) *NotificationGroup { if g != nil { g.retryCount = retryCount } return g }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/batch-expire_test.go
token: Bearer xxxxx # optional authentication token for the notification endpoint retry: attempts: 10 # number of retries for the job before giving up delay: 500ms # least amount of delay between each retry ` var job BatchJobRequest err := yaml.UnmarshalStrict([]byte(expireYaml), &job) if err != nil { t.Fatal("Failed to parse batch-job-expire yaml", err)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3K bytes - Viewed (0)