- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for resyncID (0.13 sec)
-
cmd/site-replication-utils.go
const ( siteResyncPrefix = bucketMetaPrefix + "/site-replication/resync" ) type resyncState struct { resyncID string LastSaved time.Time } //msgp:ignore siteResyncMetrics type siteResyncMetrics struct { sync.RWMutex // resyncStatus maps resync ID to resync status for peer resyncStatus map[string]SiteResyncStatus // map peer deployment ID to resync ID peerResyncMap map[string]resyncState }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (1) -
cmd/bucket-replication-utils.go
arn string resyncID string resyncBefore time.Time } // ResyncStatusType status of resync operation type ResyncStatusType int const ( // NoResync - no resync in progress NoResync ResyncStatusType = iota // ResyncPending - resync pending ResyncPending // ResyncCanceled - resync canceled ResyncCanceled // ResyncStarted - resync in progress ResyncStarted
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
cmd/bucket-replication.go
Error: errStr, Bytes: sz, } } // delete resync metadata from replication resync state in memory func (p *ReplicationPool) deleteResyncMetadata(ctx context.Context, bucket string) { if p == nil { return } p.resyncer.Lock() delete(p.resyncer.statusMap, bucket) defer p.resyncer.Unlock() globalSiteResyncMetrics.deleteBucket(bucket) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen.go
case "lst": z.LastUpdate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "LastUpdate") return } case "id": z.ResyncID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ResyncID") return } case "rdt": z.ResyncBeforeDate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ResyncBeforeDate") return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 61.1K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } if err := globalReplicationPool.resyncer.start(ctx, objectAPI, resyncOpts{ bucket: bucket, arn: arn, resyncID: resetID, resyncBefore: resetBeforeDate, }); err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrBadRequest, InvalidArgument{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
cmd/site-replication.go
OpType: "start", ResyncID: rs.ResyncID, Buckets: res.Buckets, } if len(res.Buckets) > 0 { res.ErrDetail = "partial failure in starting site resync" } if len(buckets) != 0 && len(res.Buckets) == len(buckets) { return res, fmt.Errorf("all buckets resync failed") } return res, nil } // cancelResync stops an ongoing site level resync for the peer specified.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
pkg/proxy/apis/config/types.go
// than 0. SyncPeriod metav1.Duration // minSyncPeriod is the minimum period between iptables rule resyncs (e.g. '5s', // '1m', '2h22m'). A value of 0 means every Service or EndpointSlice change will // result in an immediate iptables resync. MinSyncPeriod metav1.Duration } // KubeProxyIPVSConfiguration contains ipvs-related configuration // details for the Kubernetes proxy server.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 13K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
logger.V(4).Info("no resource updates from discovery, skipping resource quota sync") return } // Ensure workers are paused to avoid processing events before informers // have resynced. rq.workerLock.Lock() defer rq.workerLock.Unlock() // Something has changed, so track the new state and perform a sync. if loggerV := logger.V(2); loggerV.Enabled() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
} <-ctx.Done() } // Sync periodically resyncs the garbage collector when new resources are // observed from discovery. When new resources are detected, Sync will stop all // GC workers, reset gc.restMapper, and resync the monitors. // // Note that discoveryClient should NOT be shared with gc.restMapper, otherwise
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
cmd/kube-controller-manager/app/autoscaling.go
apiVersionsGetter := custom_metrics.NewAvailableAPIsGetter(hpaClient.Discovery()) // invalidate the discovery information roughly once per resync interval our API // information is *at most* two resync intervals old. go custom_metrics.PeriodicallyInvalidate( apiVersionsGetter, controllerContext.ComponentConfig.HPAController.HorizontalPodAutoscalerSyncPeriod.Duration, ctx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 01:37:36 UTC 2024 - 4.2K bytes - Viewed (0)