- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for SendEvent (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
} // send items from the response until no more results for i, kv := range getResp.Kvs { lastKey = kv.Key wc.sendEvent(parseKV(kv)) // free kv early. Long lists can take O(seconds) to decode. getResp.Kvs[i] = nil } if withRev == 0 { wc.initialRev = getResp.Header.Revision }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
cmd/data-scanner.go
if totalFolders := len(existingFolders) + len(newFolders); totalFolders > int(scannerExcessFolders.Load()) { prefixName := strings.TrimSuffix(folder.name, "/") + "/" sendEvent(eventArgs{ EventName: event.PrefixManyFolders, BucketName: f.root, Object: ObjectInfo{ Name: prefixName, Size: int64(totalFolders), }, UserAgent: "Scanner",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
cmd/object-handlers-common.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 14.6K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
RespElements: extractRespElements(w), UserAgent: r.UserAgent(), Host: handlers.GetSourceIP(r), } sendEvent(evt) if objInfo.NumVersions > int(scannerExcessObjectVersions.Load()) { evt.EventName = event.ObjectManyVersions sendEvent(evt) auditLogInternal(context.Background(), AuditLogOptions{ Event: "scanner:manyversions", APIName: "CompleteMultipartUpload",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 38.8K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
eventName = event.ObjectRemovedDeleteMarkerCreated } objInfo := ObjectInfo{ Name: oi.Name, VersionID: oi.VersionID, DeleteMarker: oi.DeleteMarker, } // Notify object deleted event. sendEvent(eventArgs{ EventName: eventName, BucketName: oi.Bucket, Object: objInfo, UserAgent: "Internal: [ILM-Expiry]", Host: globalLocalNodeName, }) return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.3K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/sink/GroupingProgressLogEventGeneratorTest.groovy
def progressEvent = new LogEvent(tenAm, CATEGORY, LogLevel.INFO, "message", null, buildOpId) def endEvent = new ProgressCompleteEvent(operationId, tenAm, "all good", false) when: listener.onOutput(downloadEvent) listener.onOutput(progressEvent) listener.onOutput(endEvent) then: 1 * downstreamListener.onOutput({ it.getMessage() == header })
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 23.9K bytes - Viewed (0)