- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for notifications (0.26 sec)
-
cmd/config-current.go
Description: "publish bucket notifications to webhook endpoints", MultipleTargets: true, }, config.HelpKV{ Key: config.NotifyAMQPSubSys, Description: "publish bucket notifications to AMQP endpoints", MultipleTargets: true, }, config.HelpKV{ Key: config.NotifyKafkaSubSys, Description: "publish bucket notifications to Kafka endpoints", MultipleTargets: true,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 11:33:28 GMT 2024 - 30.7K bytes - Viewed (0) -
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 Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/notification.go
"github.com/minio/minio/internal/bucket/bandwidth" "github.com/minio/minio/internal/logger" ) // This file contains peer related notifications. For sending notifications to // external systems, see event-notification.go // NotificationSys - notification system. type NotificationSys struct { peerClients []*peerRESTClient // Excludes self allPeerClients []*peerRESTClient // Includes nil client for self }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
internal/logger/help.go
Description: "comma separated list of Kafka broker addresses", Type: "csv", }, config.HelpKV{ Key: KafkaTopic, Description: "Kafka topic used for bucket notifications", Optional: true, Type: "string", }, config.HelpKV{ Key: KafkaSASLUsername, Description: "username for SASL/PLAIN or SASL/SCRAM authentication", Optional: true,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Mar 07 20:17:46 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/tier-handlers.go
switch cfg.Name { case storageclass.STANDARD, storageclass.RRS: writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errTierReservedName), r.URL) return } // Refresh from the disk in case we had missed notifications about edits from peers. if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 15 19:52:44 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/config/api/help.go
Optional: true, Type: "boolean", }, config.HelpKV{ Key: apiSyncEvents, Description: "set to enable synchronous bucket notifications" + defaultHelpPostfix(apiSyncEvents), Optional: true, Type: "boolean", }, config.HelpKV{ Key: apiObjectMaxVersions,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 15 01:07:19 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/config/notify/help.go
Description: "comma separated list of Kafka broker addresses", Type: "csv", }, config.HelpKV{ Key: target.KafkaTopic, Description: "Kafka topic used for bucket notifications", Optional: true, Type: "string", }, config.HelpKV{ Key: target.KafkaSASLUsername, Description: "username for SASL/PLAIN or SASL/SCRAM authentication", Optional: true,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
cmd/admin-handlers.go
services := madmin.Services{ KMS: fetchKMSStatus(), KMSStatus: fetchKMSStatusV2(ctx), LDAP: ldap, Logger: log, Audit: audit, Notifications: notifyTarget, } return madmin.InfoMessage{ Mode: string(mode), Domain: domain, Region: globalSite.Region, SQSARN: globalEventNotifier.GetARNList(false),
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/event-notification.go
} // Targets returns all the registered targets func (evnot *EventNotifier) Targets() []event.Target { return evnot.targetList.Targets() } // InitBucketTargets - initializes event notification system from notification.xml of all buckets. func (evnot *EventNotifier) InitBucketTargets(ctx context.Context, objAPI ObjectLayer) error { if objAPI == nil { return errServerNotInitialized }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.8K 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 Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 90.6K bytes - Viewed (6)