- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 33 for eventNames (0.15 sec)
-
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": {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 84K bytes - Viewed (0) -
pkg/kubelet/config/file_linux.go
func (s *sourceFile) produceWatchEvent(e *fsnotify.Event) error { // Ignore file start with dots if strings.HasPrefix(filepath.Base(e.Name), ".") { klog.V(4).InfoS("Ignored pod manifest, because it starts with dots", "eventName", e.Name) return nil } var eventType podEventType switch { case (e.Op & fsnotify.Create) > 0: eventType = podAdd case (e.Op & fsnotify.Write) > 0: eventType = podModify
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 17:27:26 UTC 2023 - 3.8K bytes - Viewed (0) -
internal/event/target/nats.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 } if target.stanConn != nil { if target.args.Streaming.Async {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0) -
internal/event/target/kafka.go
objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return nil, 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 nil, err } return &sarama.ProducerMessage{ Topic: target.args.Topic, Key: sarama.StringEncoder(key),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
eventName := event.ObjectRemovedDelete if oi.DeleteMarker { 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,
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-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheBuildServiceIntegrationTest.groovy
public ProbeService() {} public void probe(String eventName, String taskPath) { String probe = Static.probe(getParameters().getProjectName().get()); System.out.println(eventName + ": " + taskPath + ": " + probe); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 11:47:23 UTC 2024 - 29.1K bytes - Viewed (0) -
internal/event/target/redis.go
objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err } key := eventData.S3.Bucket.Name + "/" + objectName if eventData.EventName == event.ObjectRemovedDelete { _, err = conn.Do("HDEL", target.args.Key, key) } else { var data []byte if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.1K bytes - Viewed (0) -
internal/event/target/mysql.go
objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err } key := eventData.S3.Bucket.Name + "/" + objectName if eventData.EventName == event.ObjectRemovedDelete { _, err = target.deleteStmt.Exec(key) } else { var data []byte if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil { return err
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.5K bytes - Viewed (0) -
internal/event/target/postgresql.go
objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err } key := eventData.S3.Bucket.Name + "/" + objectName if eventData.EventName == event.ObjectRemovedDelete { _, err = target.deleteStmt.Exec(key) } else { var data []byte if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil { return err
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
hh.Write([]byte(key)) hashBytes := hh.Sum(nil) keyHash = base64.URLEncoding.EncodeToString(hashBytes) } else { 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 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15K bytes - Viewed (0)