- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 88 for progress (0.59 sec)
-
internal/s3select/progress.go
Klaus Post <******@****.***> 1634571876 -0700
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0) -
cmd/bucket-lifecycle_test.go
// TestRestoreObjOnDisk tests restoreObjStatus' OnDisk method func TestRestoreObjOnDisk(t *testing.T) { testCases := []struct { restoreStatus restoreObjStatus ondisk bool }{ { // restore in progress restoreStatus: ongoingRestoreObj(), ondisk: false, }, { // restore completed but expired restoreStatus: completedRestoreObj(time.Now().Add(-time.Hour)), ondisk: false,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue May 31 09:57:57 GMT 2022 - 7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
if p.Pools[idx].Decommission == nil { // Decommission not in progress. return } p.Pools[idx].Decommission.Bucket = bucket p.Pools[idx].Decommission.Object = object } func (p *poolMeta) PendingBuckets(idx int) []decomBucketInfo { if p.Pools[idx].Decommission == nil { // Decommission not in progress. return nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.3K bytes - Viewed (1) -
internal/s3select/message.go
} // newProgressMessage - creates new Progress Message. S3 periodically sends this message, if requested. // It contains information about the progress of a query that has started but has not yet completed. // // Header specification: // Progress messages contain three headers, as follows: // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-progress.png // // Payload specification:
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
internal/http/server.go
inShutdown uint32 // indicates whether the server is in shutdown or not requestCount int32 // counter holds no. of request in progress. } // GetRequestCount - returns number of request in progress. func (srv *Server) GetRequestCount() int { return int(atomic.LoadInt32(&srv.requestCount)) } // Init - init HTTP server
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/metrics-v3-cluster-notification.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" ) const ( notificationCurrentSendInProgress = "current_send_in_progress" notificationEventsErrorsTotal = "events_errors_total" notificationEventsSentTotal = "events_sent_total" notificationEventsSkippedTotal = "events_skipped_total" ) var (
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:10:35 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/rebalance-admin.go
Status string `json:"status"` // Active if rebalance is running, empty otherwise Used float64 `json:"used"` // Percentage used space Progress rebalPoolProgress `json:"progress,omitempty"` // is empty when rebalance is not running } // rebalanceAdminStatus holds rebalance status related information exported to mc, console, etc. type rebalanceAdminStatus struct {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Dec 22 00:56:43 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
// The restore operation could be in one of the following states, // - in progress (no content on MinIO's disks yet) // - completed // - completed but expired (again, no content on MinIO's disks) func (r restoreObjStatus) OnDisk() bool { if expiry, ok := r.Expiry(); ok && time.Now().UTC().Before(expiry) { // completed return true } return false // in progress or completed but expired }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/bucket-replication_test.go
rcfg: replicationConfig{Config: &configs[0]}, expectedSync: false, }, { // 4. existing object replication enabled, versioning enabled; no reset in progress name: "existing object replication enabled, versioning enabled; no reset in progress", info: ObjectInfo{ Size: 100, ReplicationStatus: replication.Completed, VersionID: "a3348c34-c352-4498-82f0-1098e8b34df9", },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Sep 16 09:28:06 GMT 2023 - 12.2K bytes - Viewed (0) -
operator/cmd/mesh/install.go
waitTimeout time.Duration, l clog.Logger, ) error { // Needed in case we are running a test through this path that doesn't start a new process. cache.FlushObjectCaches() opts := &helmreconciler.Options{ DryRun: dryRun, Log: l, WaitTimeout: waitTimeout, ProgressLog: progress.NewLog(), Force: force, } reconciler, err := helmreconciler.NewHelmReconciler(client, kubeClient, iop, opts) if err != nil { return err
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 15.2K bytes - Viewed (0)