- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 369 for Endpoints (0.04 sec)
-
cmd/config-current.go
Description: "send server logs to webhook endpoints", MultipleTargets: true, }, config.HelpKV{ Key: config.AuditWebhookSubSys, Description: "send audit logs to webhook endpoints", MultipleTargets: true, }, config.HelpKV{ Key: config.AuditKafkaSubSys, Description: "send audit logs to kafka endpoints", MultipleTargets: true, }, config.HelpKV{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 28.5K bytes - Viewed (0) -
docs/en/docs/advanced/websockets.md
## Using `Depends` and others { #using-depends-and-others } In WebSocket endpoints you can import from `fastapi` and use: * `Depends` * `Security` * `Cookie` * `Header` * `Path` * `Query` They work the same way as for other FastAPI endpoints/*path operations*: {* ../../docs_src/websockets/tutorial002_an_py310.py hl[68:69,82] *} /// info
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 5.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/BaseApiManager.java
*/ public BaseApiManager() { // Default constructor } /** * Gets the path prefix for API endpoints. * @return The path prefix. */ public String getPathPrefix() { return pathPrefix; } /** * Sets the path prefix for API endpoints. * @param pathPrefix The path prefix to set. */ public void setPathPrefix(final String pathPrefix) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 5.9K bytes - Viewed (0) -
docs/bucket/notifications/README.md
notify_webhook publish bucket notifications to webhook endpoints notify_amqp publish bucket notifications to AMQP endpoints 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
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 84.2K bytes - Viewed (0) -
cmd/endpoint_contrib_test.go
globalMinioPort = tempGlobalMinioPort }() globalMinioPort = "9000" tempGlobalDomainIPs := globalDomainIPs defer func() { globalDomainIPs = tempGlobalDomainIPs }() ipv4TestCases := []struct { endPoints set.StringSet expectedResult set.StringSet }{ {set.NewStringSet(), set.NewStringSet()}, {set.CreateStringSet("localhost"), set.NewStringSet()},
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 30 15:50:39 UTC 2021 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/ForwardingGraph.java
public boolean hasEdgeConnecting(N nodeU, N nodeV) { return delegate().hasEdgeConnecting(nodeU, nodeV); } @Override public boolean hasEdgeConnecting(EndpointPair<N> endpoints) { return delegate().hasEdgeConnecting(endpoints); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 2.5K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
return } poolIndices = append(poolIndices, idx) } if len(poolIndices) == 0 || !proxyDecommissionRequest(ctx, globalEndpoints[poolIndices[0]].Endpoints[0], w, r) { if err := z.Decommission(r.Context(), poolIndices...); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Sep 04 20:47:24 UTC 2025 - 11K bytes - Viewed (0) -
cmd/erasure-sets_test.go
t.Fatalf("Expecting error, got %s", err) } // Initializes all erasure disks storageDisks, format, err := waitForFormatErasure(true, endpoints, 1, 1, 16, "") if err != nil { t.Fatalf("Unable to format drives for erasure, %s", err) } ep := PoolEndpoints{Endpoints: endpoints} parity, err := ecDrivesNoConfig(16) if err != nil { t.Fatalf("Unexpected error during EC drive config: %v", err) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.8K bytes - Viewed (0) -
cmd/admin-heal-ops.go
func (ahs *allHealState) getHealLocalDiskEndpoints() Endpoints { ahs.RLock() defer ahs.RUnlock() var endpoints Endpoints for ep, healing := range ahs.healLocalDisks { if !healing { endpoints = append(endpoints, ep) } } return endpoints } // Set, in the memory, the state of the disk as currently healing or not func (ahs *allHealState) setDiskHealingStatus(ep Endpoint, healing bool) { ahs.Lock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
cmd/format-erasure.go
} wg.Wait() } // Initialize storage disks for each endpoint. // Errors are returned for each endpoint with matching index. func initStorageDisksWithErrors(endpoints Endpoints, opts storageOpts) ([]StorageAPI, []error) { // Bootstrap disks. storageDisks := make([]StorageAPI, len(endpoints)) g := errgroup.WithNErrs(len(endpoints)) for index := range endpoints { g.Go(func() (err error) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 23.1K bytes - Viewed (0)