- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,695 for _targets (6.23 sec)
-
internal/bucket/replication/replication.go
continue } if obj.TargetArn != "" && rule.Destination.ARN != obj.TargetArn && c.RoleArn != obj.TargetArn { continue } // Ignore other object level and prefix filters for resyncing target/listing bucket targets if obj.OpType == ResyncReplicationType || obj.OpType == AllReplicationType { rules = append(rules, rule) continue } if obj.ExistingObject && rule.ExistingObjectReplication.Status == Disabled {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_notify_events_errors_total` | Events that were failed to be sent to the targets (deprecated, please use 'minio_notify_target_failed_events' instead) |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedSet.java
@Override public boolean containsAll(Collection<?> targets) { for (Object target : targets) { if (target == null) { // This set never contains null. We need to explicitly check here // because some comparator might throw NPE (e.g. the natural ordering). return false; } } try { return sortedDelegate.containsAll(targets); } catch (ClassCastException e) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 27 19:19:19 GMT 2024 - 15.3K bytes - Viewed (0) -
internal/logger/audit.go
auditEntry := GetAuditEntry(ctx) if auditEntry != nil { entry = *auditEntry } } // Send audit logs only to http targets. for _, t := range auditTgts { if err := t.Send(ctx, entry); err != nil { LogOnceIf(ctx, "logging", fmt.Errorf("Unable to send an audit event to the target `%v`: %v", t, err), "send-audit-event-failure") } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/logger/config.go
envs := env.List(legacyEnvLoggerHTTPEndpoint) for _, k := range envs { target := strings.TrimPrefix(k, legacyEnvLoggerHTTPEndpoint+config.Default) if target == legacyEnvLoggerHTTPEndpoint { target = config.Default } loggerTargets = append(loggerTargets, target) } // Load HTTP logger from the environment if found for _, target := range loggerTargets {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.8K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt
workingOnly = false, getOnly = false, ) runBatch(dnsProviders, names) val dnsCache = Cache( directory = File("./target/TestDohMain.cache.${System.currentTimeMillis()}"), maxSize = 10L * 1024 * 1024, ) println("Bad targets\n***********\n") val url = "https://dns.cloudflare.com/.not-so-well-known/run-dmc-query".toHttpUrl() val badProviders = listOf(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_cluster_audit_target_queue_length` | `gauge` | Number of unsent messages in queue for target | `target_id` | | `minio_cluster_audit_total_messages` | `counter` | Total number of messages sent since start | `target_id` | ### `/cluster/usage/objects`
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) -
internal/config/notify/help.go
) // Help template inputs for all notification targets var ( HelpWebhook = config.HelpKVS{ config.HelpKV{ Key: target.WebhookEndpoint, Description: "webhook server endpoint e.g. http://localhost:8080/minio/events", Type: "url", Sensitive: true, }, config.HelpKV{ Key: target.WebhookAuthToken, Description: "opaque string or JWT authorization token",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
cmd/config-current.go
transport := NewHTTPTransport() bootstrapTraceMsg("initialize the event notification targets") globalNotifyTargetList, err = notify.FetchEnabledTargets(GlobalContext, s, transport) if err != nil { configLogIf(ctx, fmt.Errorf("Unable to initialize notification target(s): %w", err)) } bootstrapTraceMsg("initialize the lambda targets") globalLambdaTargetList, err = lambda.FetchEnabledTargets(GlobalContext, s, transport)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
// assign the new webhook target to this field. // The Send() method will then re-direct entries // to the new target when the current one // has been set to status "statusClosed". // Once the glogal target slice has been migrated // the current target will stop receiving entries. migrateTarget *Target // Number of events per HTTP send to webhook target // this is ideally useful only if your endpoint can
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0)