- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for enqueue (0.15 sec)
-
internal/event/target/webhook.go
WebhookAuthToken = "auth_token" WebhookQueueDir = "queue_dir" WebhookQueueLimit = "queue_limit" WebhookClientCert = "client_cert" WebhookClientKey = "client_key" EnvWebhookEnable = "MINIO_NOTIFY_WEBHOOK_ENABLE" EnvWebhookEndpoint = "MINIO_NOTIFY_WEBHOOK_ENDPOINT" EnvWebhookAuthToken = "MINIO_NOTIFY_WEBHOOK_AUTH_TOKEN" EnvWebhookQueueDir = "MINIO_NOTIFY_WEBHOOK_QUEUE_DIR"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
cmd/data-scanner_test.go
t.Fatalf("Failed with err: %v", err) } if len(gots) != len(wants) { t.Fatalf("Expected %d objects but got %d", len(wants), len(gots)) } // Close expiry state's channel to inspect object versions enqueued for expiration close(workers[0]) wg.Wait() for _, obj := range expired { switch obj.ObjectV.VersionID { case uuids[2].String(), uuids[3].String(), uuids[4].String(): default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
cmd/metrics-v3-cluster-notification.go
notificationEventsSkippedTotalMD = NewCounterMD(notificationEventsSkippedTotal, "Events that were skipped to be sent to the targets due to the in-memory queue being full") ) // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics. func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:10:35 GMT 2024 - 2.2K bytes - Viewed (0) -
docs/throttle/README.md
MinIO server allows to throttle incoming requests: - limit the number of active requests allowed across the cluster - limit the wait duration for each request in the queue These values are enabled using server's configuration or environment variables. ## Examples ### Configuring connection limit
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Feb 12 00:51:25 GMT 2022 - 2.4K bytes - Viewed (0) -
internal/store/queuestore_test.go
// Ext for test item testItemExt = ".test" ) // Initialize the queue store. func setUpQueueStore(directory string, limit uint64) (Store[TestItem], error) { queueStore := NewQueueStore[TestItem](queueDir, limit, testItemExt) if oErr := queueStore.Open(); oErr != nil { return nil, oErr } return queueStore, nil } // Tear down queue store. func tearDownQueueStore() error { return os.RemoveAll(queueDir) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 04 17:52:24 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/event/errors.go
} // ErrDuplicateQueueConfiguration - duplicate queue configuration error. type ErrDuplicateQueueConfiguration struct { Queue Queue } func (err ErrDuplicateQueueConfiguration) Error() string { var message string if data, xerr := xml.Marshal(err.Queue); xerr != nil { message = fmt.Sprintf("%+v", err.Queue) } else { message = string(data) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 4.1K bytes - Viewed (0) -
internal/event/target/redis.go
) // Redis constants const ( RedisFormat = "format" RedisAddress = "address" RedisPassword = "password" RedisUser = "user" RedisKey = "key" RedisQueueDir = "queue_dir" RedisQueueLimit = "queue_limit" EnvRedisEnable = "MINIO_NOTIFY_REDIS_ENABLE" EnvRedisFormat = "MINIO_NOTIFY_REDIS_FORMAT" EnvRedisAddress = "MINIO_NOTIFY_REDIS_ADDRESS"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/metrics-v3-cluster-audit.go
auditTargetQueueLength = "target_queue_length" auditTotalMessages = "total_messages" targetID = "target_id" ) var ( auditFailedMessagesMD = NewCounterMD(auditFailedMessages, "Total number of messages that failed to send since start", targetID) auditTargetQueueLengthMD = NewGaugeMD(auditTargetQueueLength, "Number of unsent messages in queue for target", targetID)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 09:18:02 GMT 2024 - 1.9K bytes - Viewed (0) -
internal/logger/target/types/types.go
// Constants for target types const ( _ TargetType = iota TargetConsole TargetHTTP TargetKafka ) // TargetStats contains statistics for a target. type TargetStats struct { // QueueLength is the queue length if any messages are queued. QueueLength int // TotalMessages is the total number of messages sent in the lifetime of the target TotalMessages int64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 10 18:20:21 GMT 2022 - 1.4K bytes - Viewed (0) -
internal/s3select/json/preader.go
r.bufferPool.New = func() interface{} { return make([]byte, jsonSplitSize+1024) } // Create queue r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.input = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.readerWg.Add(1) // Start splitter go func() { defer close(r.input) defer close(r.queue) defer r.readerWg.Done() for { next, err := r.nextSplit(jsonSplitSize, r.bufferPool.Get().([]byte))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0)