- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for eventData (0.05 sec)
-
internal/event/target/elasticsearch.go
keyHash = key } } if eventData.EventName == event.ObjectRemovedDelete { err = target.client.removeEntry(ctx, target.args.Index, keyHash) } else { err = target.client.updateEntry(ctx, target.args.Index, keyHash, eventData) } return err } if target.args.Format == event.AccessFormat { return target.client.addEntry(ctx, target.args.Index, eventData) } return nil }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15K bytes - Viewed (0) -
internal/event/target/amqp.go
func (target *AMQPTarget) send(eventData event.Event, ch *amqp091.Channel, confirms chan amqp091.Confirmation) error { objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err } key := eventData.S3.Bucket.Name + "/" + objectName data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}}) if err != nil { return err }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Aug 21 04:25:07 UTC 2025 - 10K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
return } eventData, err := getLambdaEventData(bucket, object, cred, r) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } resp, err := target.Send(eventData) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } defer resp.Body.Close()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jul 18 21:56:31 UTC 2025 - 6.5K bytes - Viewed (0) -
internal/store/queuestore.go
return err } // write - writes an item to the directory. func (store *QueueStore[I]) write(key Key, item I) error { // Marshals the item. eventData, err := json.Marshal(item) if err != nil { return err } return store.writeBytes(key, eventData) } // writeBytes - writes bytes to the directory. func (store *QueueStore[I]) writeBytes(key Key, b []byte) (err error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 7.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
return h, nil } // SendFromStore - reads the log from store and sends it to webhook. func (h *Target) SendFromStore(key store.Key) (err error) { var eventData []byte eventData, err = h.store.GetRaw(key) if err != nil { if os.IsNotExist(err) { return nil } return err } count := 1 v := strings.Split(key.Name, ":") if len(v) == 2 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
docs/bucket/notifications/README.md
When the _access_ format is used, MinIO appends events to a table. It creates rows with two columns: event_time and event_data. The event_time is the time at which the event occurred in the MinIO server. The event_data is the JSON encoded event data about the operation on an object. No rows are deleted or modified in this format.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 84.2K bytes - Viewed (0)