Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 369 for Endpoints (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top