Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 18 of 18 for eventData (0.12 sec)

  1. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. internal/store/queuestore.go

    			// Upon error we remove the entry.
    			store.Del(key)
    		}
    	}(store)
    
    	var eventData []byte
    	eventData, err = os.ReadFile(filepath.Join(store.directory, key.String()))
    	if err != nil {
    		return item, err
    	}
    
    	if len(eventData) == 0 {
    		return item, os.ErrNotExist
    	}
    
    	if err = json.Unmarshal(eventData, &item); err != nil {
    		return item, err
    	}
    
    	return item, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  3. internal/event/targetlist_test.go

    	return target.id
    }
    
    // Save - Sends event directly without persisting.
    func (target ExampleTarget) Save(eventData Event) error {
    	return target.send(eventData)
    }
    
    // Store - Returns a nil store.
    func (target ExampleTarget) Store() TargetStore {
    	return nil
    }
    
    func (target ExampleTarget) send(eventData Event) error {
    	b := make([]byte, 1)
    	if _, err := rand.Read(b); err != nil {
    		panic(err)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  4. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. internal/config/lambda/target/webhook.go

    		TotalRequests:  atomic.LoadInt64(&target.totalRequests),
    		FailedRequests: atomic.LoadInt64(&target.failedRequests),
    	}
    }
    
    // Send - sends an event to the webhook.
    func (target *WebhookTarget) Send(eventData event.Event) (resp *http.Response, err error) {
    	atomic.AddInt64(&target.activeRequests, 1)
    	defer atomic.AddInt64(&target.activeRequests, -1)
    
    	atomic.AddInt64(&target.totalRequests, 1)
    	defer func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  7. src/main/webapp/js/jquery-3.7.1.min.map

    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 131.6K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/jquery-3.7.1.min.map

    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 131.6K bytes
    - Viewed (0)
Back to top