- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 75 for notification (0.17 sec)
-
internal/event/target/nats.go
} } return nil } // To obtain a nats connection from args. func (n NATSArgs) connectNats() (*nats.Conn, error) { connOpts := []nats.Option{nats.Name("Minio Notification"), nats.MaxReconnects(-1)} if n.Username != "" && n.Password != "" { connOpts = append(connOpts, nats.UserInfo(n.Username, n.Password)) } if n.UserCredentials != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
docs/config/README.md
notify_kafka publish bucket notifications to Kafka endpoints notify_mqtt publish bucket notifications to MQTT endpoints notify_nats publish bucket notifications to NATS endpoints notify_nsq publish bucket notifications to NSQ endpoints notify_mysql publish bucket notifications to MySQL databases notify_postgres publish bucket notifications to Postgres databases
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 17.7K bytes - Viewed (0) -
cmd/api-errors.go
Description: "The transition storage class was not found", HTTPStatusCode: http.StatusNotFound, }, // Bucket notification related errors. ErrEventNotification: { Code: "InvalidArgument", Description: "A specified event is not supported for notifications.", HTTPStatusCode: http.StatusBadRequest, }, ErrARNNotification: { Code: "InvalidArgument",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
docs/metrics/v3.md
| `minio_cluster_notification_current_send_in_progress` | `counter` | Number of concurrent async Send calls active to all targets | | | `minio_cluster_notification_events_errors_total` | `counter` | Events that were failed to be sent to the targets | |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 28.5K bytes - Viewed (0) -
docs/bucket/lifecycle/README.md
Note that transition event notification is a MinIO extension. ## Explore Further - [MinIO | Golang Client API Reference](https://min.io/docs/minio/linux/developers/go/API.html)
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Aug 26 07:33:25 GMT 2023 - 9K bytes - Viewed (1) -
cmd/batch-expire.go
// # retainVersions: 5 # keep the latest 5 versions of the object including delete markers. // // notify: // endpoint: https://notify.endpoint # notification endpoint to receive job completion status // token: Bearer xxxxx # optional authentication token for the notification endpoint // // retry: // attempts: 10 # number of retries for the job before giving up // delay: 500ms # least amount of delay between each retry
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
docs/site-replication/README.md
> NOTE: Bucket versioning is automatically enabled for all new and existing buckets on all replicated sites. The following Bucket features will **not be replicated**, is designed to differ between sites: - Bucket notification configuration - Bucket lifecycle (ILM) configuration ## Pre-requisites
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 21:30:28 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/api-router.go
Queries("versioning", "") // GetBucketNotification router.Methods(http.MethodGet). HandlerFunc(s3APIMiddleware(api.GetBucketNotificationHandler)). Queries("notification", "") // ListenNotification router.Methods(http.MethodGet). HandlerFunc(s3APIMiddleware(api.ListenNotificationHandler, noThrottleS3HFlag)). Queries("events", "{events:.*}")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
cmd/handler-utils.go
cred, _, _ = getReqAccessKeyV4(r, region, serviceS3) if cred.AccessKey == "" { cred, _, _ = getReqAccessKeyV2(r) } return cred } // Extract request params to be sent with event notification. func extractReqParams(r *http.Request) map[string]string { if r == nil { return nil } region := globalSite.Region cred := getReqAccessCred(r, region) principalID := cred.AccessKey
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
internal/event/targetlist.go
}: case <-list.ctx.Done(): list.eventsSkipped.Add(int64(len(list.queue))) return default: list.eventsSkipped.Add(1) err := fmt.Errorf("concurrent target notifications exceeded %d, configured notification target is too slow to accept events for the incoming request rate", maxConcurrentAsyncSend) for id := range targetIDset { reqInfo := &logger.ReqInfo{} reqInfo.AppendTags("targetID", id.String())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0)