- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for SendEvent (0.29 sec)
-
pkg/kubelet/pluginmanager/pluginwatcher/example_handler.go
} return nil } func (p *exampleHandler) DeRegisterPlugin(pluginName string) { p.SendEvent(pluginName, exampleEventDeRegister) } func (p *exampleHandler) SendEvent(pluginName string, event examplePluginEvent) { klog.V(2).InfoS("Sending event for plugin", "pluginName", pluginName, "event", event, "channel", p.eventChans[pluginName])
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 12:00:49 UTC 2023 - 4.6K bytes - Viewed (0) -
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/bucket-replication.go
sendEvent(eventArgs{ BucketName: bucket, Object: ObjectInfo{ Bucket: bucket, Name: dobj.ObjectName, VersionID: versionID, DeleteMarker: dobj.DeleteMarker, }, UserAgent: "Internal: [Replication]", Host: globalLocalNodeName, EventName: eventName, }) } else { sendEvent(eventArgs{ BucketName: 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/object-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: "PutObject",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
cmd/bucket-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Notify object created events. sendEvent(eventArgsList[i]) if eventArgsList[i].Object.NumVersions > int(scannerExcessObjectVersions.Load()) { // Send events for excessive versions. sendEvent(eventArgs{ EventName: event.ObjectManyVersions, BucketName: eventArgsList[i].Object.Bucket,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
cmd/event-notification.go
if stringsHasPrefixFold(strings.ToLower(k), ReservedMetadataPrefixLower) { continue } newEvent.S3.Object.UserMetadata[k] = v } } return newEvent } func sendEvent(args eventArgs) { // avoid generating a notification for REPLICA creation event. if _, ok := args.ReqParams[xhttp.MinIOSourceReplicationRequest]; ok { return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.8K 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)