Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for eventData (0.45 sec)

  1. internal/event/target/redis.go

    	conn := target.pool.Get()
    	defer conn.Close()
    
    	if target.args.Format == event.NamespaceFormat {
    		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
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  2. 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)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  3. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. internal/event/target/mqtt.go

    }
    
    // send - sends an event to the mqtt.
    func (target *MQTTTarget) send(eventData event.Event) 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. internal/event/target/mysql.go

    	if target.args.Format == event.NamespaceFormat {
    		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
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. internal/event/target/postgresql.go

    }
    
    // send - sends an event to the PostgreSQL.
    func (target *PostgreSQLTarget) send(eventData event.Event) error {
    	if target.args.Format == event.NamespaceFormat {
    		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 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. internal/event/target/webhook.go

    // send - sends an event to the webhook.
    func (target *WebhookTarget) send(eventData event.Event) 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  9. internal/event/target/kafka.go

    }
    
    func (target *KafkaTarget) toProducerMessage(eventData event.Event) (*sarama.ProducerMessage, error) {
    	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
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  10. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
Back to top