- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 23 for eventTime (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/event-notification.go
} newEvent := event.Event{ EventVersion: "2.0", EventSource: "minio:s3", AwsRegion: args.ReqParams["region"], EventTime: eventTime.Format(event.AMZTimeFormat), EventName: args.EventName, UserIdentity: event.Identity{PrincipalID: args.ReqParams["principalId"]}, RequestParameters: args.ReqParams, ResponseElements: respElements, S3: event.Metadata{Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jun 21 22:22:24 GMT 2024 - 7.7K bytes - Click Count (0) -
internal/event/target/redis.go
} if err != nil { return err } } if target.args.Format == event.AccessFormat { data, err := json.Marshal([]RedisAccessEvent{{Event: []event.Event{eventData}, EventTime: eventData.EventTime}}) if err != nil { return err } if _, err := conn.Do("RPUSH", target.args.Key, data); err != nil { return err } } return nil }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 9.1K bytes - Click Count (0) -
internal/event/target/postgresql.go
return err } if target.args.Format == event.AccessFormat { eventTime, err := time.Parse(event.AMZTimeFormat, eventData.EventTime) if err != nil { return err } data, err := json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}) if err != nil { return err } if _, err = target.insertStmt.Exec(eventTime, data); err != nil { return err } } return nilCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 13.3K bytes - Click Count (0) -
docs/bucket/notifications/README.md
``` kafkacat -b localhost:9092 -t bucketevents { "EventName": "s3:ObjectCreated:Put", "Key": "images/myphoto.jpg", "Records": [ { "eventVersion": "2.0", "eventSource": "minio:s3", "awsRegion": "", "eventTime": "2019-09-10T17:41:54Z", "eventName": "s3:ObjectCreated:Put", "userIdentity": {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 84.2K bytes - Click Count (0) -
internal/event/name.go
func (name *Name) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { var s string if err := d.DecodeElement(&s, &start); err != nil { return err } eventName, err := ParseName(s) if err != nil { return err } *name = eventName return nil } // MarshalJSON - encodes to JSON data. func (name Name) MarshalJSON() ([]byte, error) { return json.Marshal(name.String()) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 10.4K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/monitor/event/EventMonitor.java
*/ package org.apache.maven.monitor.event; /** */ @Deprecated public interface EventMonitor { void startEvent(String eventName, String target, long timestamp); void endEvent(String eventName, String target, long timestamp); void errorEvent(String eventName, String target, long timestamp, Throwable cause);Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 1.1K bytes - Click Count (0) -
internal/event/config.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.4K bytes - Click Count (0) -
cmd/bucket-replication.go
}, UserAgent: "Internal: [Replication]", Host: globalLocalNodeName, EventName: eventName, }) } else { sendEvent(eventArgs{ BucketName: bucket, Object: dobjInfo, UserAgent: "Internal: [Replication]", Host: globalLocalNodeName, EventName: eventName, }) } }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 118.2K bytes - Click Count (0) -
cmd/data-scanner.go
auditLogLifecycle(ctx, dobj, ILMExpiry, tags, traceFn) eventName := event.ObjectRemovedDelete if obj.DeleteMarker { eventName = event.ObjectRemovedDeleteMarkerCreated } switch lcEvent.Action { case lifecycle.DeleteAllVersionsAction: eventName = event.ObjectRemovedDeleteAllVersions case lifecycle.DelMarkerDeleteAllVersionsAction: eventName = event.ILMDelMarkerExpirationDelete }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 45.5K bytes - Click Count (0) -
internal/event/target/nsq.go
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 } return target.producer.Publish(target.args.Topic, data) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0)