Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 277 for mkchan (0.06 sec)

  1. docs/es/docs/advanced/response-headers.md

    **FastAPI** proporciona las mismas `starlette.responses` en `fastapi.responses` sólo que de una manera más conveniente para ti, el desarrollador. En otras palabras, muchas de las responses disponibles provienen directamente de Starlette.
    
    
    Y como la `Response` puede ser usada frecuentemente para configurar headers y cookies, **FastAPI** también la provee en `fastapi.Response`.
    
    ///
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. cmd/notification.go

    			}
    			consolidatedReport.BucketStats[opts] = d
    		}
    	}
    	return consolidatedReport
    }
    
    func (sys *NotificationSys) collectPeerMetrics(ctx context.Context, peerChannels []<-chan MetricV2, g *errgroup.Group) <-chan MetricV2 {
    	ch := make(chan MetricV2)
    	var wg sync.WaitGroup
    	for index, err := range g.Wait() {
    		if err != nil {
    			if sys.peerClients[index] != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. internal/dsync/dsync_test.go

    // Borrowed from mutex_test.go
    func HammerMutex(m *DRWMutex, loops int, cdone chan bool) {
    	for i := 0; i < loops; i++ {
    		m.Lock(id, source)
    		m.Unlock(context.Background())
    	}
    	cdone <- true
    }
    
    // Borrowed from mutex_test.go
    func TestMutex(t *testing.T) {
    	loops := 200
    	if testing.Short() {
    		loops = 5
    	}
    	c := make(chan bool)
    	m := NewDRWMutex(ds, "test")
    	for i := 0; i < 10; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. internal/s3select/message.go

    	getProgressFunc func() (int64, int64)
    	bytesReturned   int64
    
    	payloadBuffer      []byte
    	payloadBufferIndex int
    	payloadCh          chan *bytes.Buffer
    
    	finBytesScanned, finBytesProcessed int64
    
    	errCh  chan []byte
    	doneCh chan struct{}
    }
    
    func (writer *messageWriter) write(data []byte) bool {
    	if _, err := writer.writer.Write(data); err != nil {
    		return false
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  5. docs/de/docs/advanced/openapi-webhooks.md

    Dies kann es Ihren Benutzern viel einfacher machen, **deren APIs zu implementieren**, um Ihre **Webhook**-Requests zu empfangen. Möglicherweise können diese sogar einen Teil des eigenem API-Codes automatisch generieren.
    
    /// info
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. docs/de/docs/tutorial/request-forms.md

    ///
    
    ```Python hl_lines="1"
    {!> ../../docs_src/request_forms/tutorial001.py!}
    ```
    
    ////
    
    ## `Form`-Parameter definieren
    
    Erstellen Sie Formular-Parameter, so wie Sie es auch mit `Body` und `Query` machen würden:
    
    //// tab | Python 3.9+
    
    ```Python hl_lines="9"
    {!> ../../docs_src/request_forms/tutorial001_an_py39.py!}
    ```
    
    ////
    
    //// tab | Python 3.8+
    
    ```Python hl_lines="8"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  7. docs/es/docs/benchmarks.md

    ## Benchmarks y velocidad
    
    Cuando revisas los benchmarks, es común ver varias herramientas de diferentes tipos comparadas como equivalentes.
    
    Específicamente, para ver Uvicorn, Starlette y FastAPI comparadas entre sí (entre muchas otras herramientas).
    
    Cuanto más sencillo sea el problema resuelto por la herramienta, mejor rendimiento obtendrá. Y la mayoría de los benchmarks no prueban las funciones adicionales proporcionadas por la herramienta.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Feb 07 11:39:50 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. internal/event/target/amqp.go

    		confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1))
    		if err := ch.Confirm(false); err != nil {
    			ch.Close()
    			return nil, nil, err
    		}
    		return ch, confirms, nil
    	}
    
    	return ch, nil, nil
    }
    
    // send - sends an event to the AMQP091.
    func (target *AMQPTarget) send(eventData event.Event, ch *amqp091.Channel, confirms chan amqp091.Confirmation) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  9. cmd/mrf.go

    }
    
    // mrfState sncapsulates all the information
    // related to the global background MRF.
    type mrfState struct {
    	opCh chan PartialOperation
    
    	closed  int32
    	closing int32
    	wg      sync.WaitGroup
    }
    
    func newMRFState() mrfState {
    	return mrfState{
    		opCh: make(chan PartialOperation, mrfOpsQueueSize),
    	}
    }
    
    // Add a partial S3 operation (put/delete) when one or more disks are offline.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  10. internal/once/singleton.go

    // Singleton contains a pointer to T that must be set once.
    // Until the value is set all Get() calls will block.
    type Singleton[T any] struct {
    	v   *T
    	set chan struct{}
    }
    
    // NewSingleton creates a new unset singleton.
    func NewSingleton[T any]() *Singleton[T] {
    	return &Singleton[T]{set: make(chan struct{}), v: nil}
    }
    
    // Get will return the singleton value.
    func (s *Singleton[T]) Get() *T {
    	<-s.set
    	return s.v
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
Back to top