- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for eventData (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
src/main/webapp/js/jquery-3.7.1.min.map
,"toggleClass","stateVal","isValidValue","hasClass","rreturn","valHooks","optionSet","rquery","parseXML","parserErrorElem","DOMParser","parseFromString","rfocusMorph","stopPropagationCallback","onlyHandlers","bubbleType","ontype","lastElement","eventPath","parentWindow","triggerHandler","rbracket","rCRLF","rsubmitterTypes","rsubmittable","buildParams","traditional","param","s","valueOrFunction","encodeURIComponent","serialize","serializeArray","r20","rhash","rantiCache","rheaders","rnoContent","...
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Sat Oct 26 01:07:52 UTC 2024 - 131.6K bytes - Viewed (0) -
src/main/webapp/js/admin/jquery-3.7.1.min.map
,"toggleClass","stateVal","isValidValue","hasClass","rreturn","valHooks","optionSet","rquery","parseXML","parserErrorElem","DOMParser","parseFromString","rfocusMorph","stopPropagationCallback","onlyHandlers","bubbleType","ontype","lastElement","eventPath","parentWindow","triggerHandler","rbracket","rCRLF","rsubmitterTypes","rsubmittable","buildParams","traditional","param","s","valueOrFunction","encodeURIComponent","serialize","serializeArray","r20","rhash","rantiCache","rheaders","rnoContent","...
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Sat Oct 26 01:07:52 UTC 2024 - 131.6K bytes - Viewed (0)