- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 66 for ending1 (0.18 sec)
-
cmd/batch-expire.go
time.Sleep(delay) } } }(toExpire) } } type expireObjInfo struct { ObjectInfo ExpireAll bool } // Start the batch expiration job, resumes if there was a pending job via "job.ID" func (r *BatchJobExpire) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error { ri := &batchJobInfo{ JobID: job.ID, JobType: string(job.Type()), StartTime: job.Started,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/object-api-datatypes.go
// value of true indicates that the list was truncated. The list can be truncated // if the number of multipart uploads exceeds the limit allowed or specified // by max uploads. IsTruncated bool // List of all pending uploads. Uploads []MultipartInfo // When a prefix is provided in the request, The result contains only keys // starting with the specified prefix. Prefix string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
internal/grid/muxclient.go
select { case <-m.ctx.Done(): if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) } m.addErrorNonBlockingClose(internalResp, context.Cause(m.ctx)) errState = true continue case req, ok := <-requests: if !ok { // Done send EOF if debugPrint { fmt.Println("Client done, sending EOF to mux", m.MuxID) } msg := message{ Op: OpMuxClientMsg,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
fd := int(wl.Netns.Fd()) log.Infof("Sending local pod %s ztunnel", uid) resp, err = conn.sendMsgAndWaitForAck(&zdsapi.WorkloadRequest{ Payload: &zdsapi.WorkloadRequest_Add{ Add: &zdsapi.AddWorkload{ Uid: uid, WorkloadInfo: wl.Workload, }, }, }, &fd) } else { log.Infof("netns not available for local pod %s. sending keep to ztunnel", uid)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/grid/grid_test.go
t.Errorf("want %q, got %q", testPayload+strconv.Itoa(n), string(resp.Msg)) } if n == 10 { close(stream.Requests) continue } n++ t.Log("sending new client request") stream.Requests <- []byte(strconv.Itoa(n)) } t.Log("EOF. 10 Roundtrips:", time.Since(start)) } func testStreamCancel(t *testing.T, local, remote *Manager) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/bucket/replication/datatypes.go
//go:generate msgp -file=$GOFILE // StatusType of Replication for x-amz-replication-status header type StatusType string // Type - replication type enum type Type int const ( // Pending - replication is pending. Pending StatusType = "PENDING" // Completed - replication completed ok. Completed StatusType = "COMPLETED" // CompletedLegacy was called "COMPLETE" incorrectly. CompletedLegacy StatusType = "COMPLETE"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 1.5K bytes - Viewed (0) -
cmd/bucket-lifecycle_test.go
func TestParseRestoreObjStatus(t *testing.T) { testCases := []struct { restoreHdr string expectedStatus restoreObjStatus expectedErr error }{ { // valid: represents a restored object, 'pending' expiry. restoreHdr: `ongoing-request="false", expiry-date="Fri, 21 Dec 2012 00:00:00 GMT"`, expectedStatus: restoreObjStatus{ ongoing: false, expiry: time.Date(2012, 12, 21, 0, 0, 0, 0, time.UTC), },
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/site-replication-metrics.go
srs.Latency.update(st.TransferSize, st.TransferDuration) srs.updateXferRate(st.TransferSize, st.TransferDuration) } case st.Failed: srs.Failed.addsize(st.TransferSize, st.Err) case st.Pending: } sr.M[dID] = srs } func (sr *SRStats) get() map[string]SRMetric { epMap := globalBucketTargetSys.healthStats() sr.lock.RLock() defer sr.lock.RUnlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
internal/event/targetlist.go
// any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock() defer list.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} } func (z *erasureServerPools) decommissionInBackground(ctx context.Context, idx int) error { pool := z.serverPools[idx] z.poolMetaMutex.RLock() pending := z.poolMeta.PendingBuckets(idx) z.poolMetaMutex.RUnlock() for _, bucket := range pending { z.poolMetaMutex.RLock() isDecommissioned := z.poolMeta.isBucketDecommissioned(idx, bucket.String()) z.poolMetaMutex.RUnlock() if isDecommissioned {
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)