Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 382 for seventy (0.25 sec)

  1. internal/event/target/nsq.go

    }
    
    // send - sends an event to the NSQ.
    func (target *NSQTarget) 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
    - 7.1K bytes
    - Viewed (0)
  2. internal/event/target/redis.go

    }
    
    // RedisAccessEvent holds event log data and timestamp
    type RedisAccessEvent struct {
    	Event     []event.Event
    	EventTime string
    }
    
    // Validate RedisArgs fields
    func (r RedisArgs) Validate() error {
    	if !r.Enable {
    		return nil
    	}
    
    	if r.Format != "" {
    		f := strings.ToLower(r.Format)
    		if f != event.NamespaceFormat && f != event.AccessFormat {
    			return fmt.Errorf("unrecognized format")
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. cmd/object-lambda-handlers.go

    	if err != nil {
    		return levent.Event{}, err
    	}
    
    	ckSum := sha256.Sum256([]byte(cred.AccessKey + u.RawQuery))
    
    	eventData := levent.Event{
    		GetObjectContext: &levent.GetObjectContext{
    			InputS3URL:  u.String(),
    			OutputRoute: shortuuid.New(),
    			OutputToken: hex.EncodeToString(ckSum[:]),
    		},
    		UserRequest: levent.UserRequest{
    			URL:     r.URL.String(),
    			Headers: r.Header.Clone(),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  4. docs/zh/docs/advanced/testing-events.md

    Sebastián Ramírez <******@****.***> 1728247014 +0200
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 225 bytes
    - Viewed (0)
  5. docs/em/docs/advanced/testing-events.md

    Sebastián Ramírez <******@****.***> 1728247014 +0200
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 245 bytes
    - Viewed (0)
  6. internal/event/target/amqp.go

    func NewAMQPTarget(id string, args AMQPArgs, loggerOnce logger.LogOnce) (*AMQPTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-amqp-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  7. docs/pt/docs/advanced/testing-events.md

    Sebastián Ramírez <******@****.***> 1728247014 +0200
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 316 bytes
    - Viewed (0)
  8. internal/event/target/webhook.go

    	}
    	return err
    }
    
    // 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/logger/help.go

    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         Proxy,
    			Description: "proxy url endpoint e.g. http(s)://proxy",
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         MaxRetry,
    			Description: `maximum retry count before we start dropping logged event(s)`,
    			Optional:    true,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  10. internal/event/target/mysql.go

    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    				return err
    			}
    
    			_, err = target.updateStmt.Exec(key, data)
    		}
    
    		return err
    	}
    
    	if target.args.Format == event.AccessFormat {
    		eventTime, err := time.Parse(event.AMZTimeFormat, eventData.EventTime)
    		if err != nil {
    			return err
    		}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
Back to top