- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 59 for progress (0.33 sec)
-
internal/s3select/progress.go
Klaus Post <******@****.***> 1634571876 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0) -
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 May 05 19:28:20 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 May 05 19:28:20 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 May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:10:35 GMT 2024 - 2.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 May 05 19:28:20 GMT 2024 - Last Modified: Tue May 31 09:57:57 GMT 2022 - 7K bytes - Viewed (0) -
cmd/storage-errors.go
// errDiskNotFound - cannot find the underlying configured disk anymore. var errDiskNotFound = StorageErr("drive not found") // errDiskOngoingReq - indicates if the disk has an on-going request in progress. var errDiskOngoingReq = StorageErr("drive still did not complete the request") // errDriveIsRoot - cannot use the disk since its a root disk. var errDriveIsRoot = StorageErr("drive is part of root drive, will not be used")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/update.go
) func verifyBinary(u *url.URL, sha256Sum []byte, releaseInfo, mode string, reader io.Reader) (err error) { if !updateInProgress.CompareAndSwap(0, 1) { return errors.New("update already in progress") } defer updateInProgress.Store(0) transport := getUpdateTransport(30 * time.Second) opts := selfupdate.Options{ Hash: crypto.SHA256, Checksum: sha256Sum, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
internal/s3select/select.go
ExpressionType string `xml:"ExpressionType"` Input InputSerialization `xml:"InputSerialization"` Output OutputSerialization `xml:"OutputSerialization"` Progress RequestProgress `xml:"RequestProgress"` ScanRange *ScanRange `xml:"ScanRange"` statement *sql.SelectStatement progressReader *progressReader recordReader recordReader }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
internal/s3select/genmessage.go
buf.WriteByte(7) buf.Write([]byte{0, 8}) buf.WriteString("text/xml") buf.WriteByte(11) buf.WriteString(":event-type") buf.WriteByte(7) buf.Write([]byte{0, 8}) buf.WriteString("Progress") fmt.Println(buf.Bytes()) } func genStatsHeader() { buf := new(bytes.Buffer) buf.WriteByte(13) buf.WriteString(":message-type") buf.WriteByte(7) buf.Write([]byte{0, 5})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K 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 May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1)