Search Options

Results per page
Sort
Preferred Languages
Advance

Results 471 - 480 of 744 for callEnd (0.07 sec)

  1. internal/logger/target/http/http.go

    	}
    
    	// Delete the event from store.
    	return h.store.Del(key)
    }
    
    // Send the log message 'entry' to the http target.
    // Messages are queued in the disk if the store is enabled
    // If Cancel has been called the message is ignored.
    func (h *Target) Send(ctx context.Context, entry interface{}) error {
    	if h.status.Load() == statusClosed {
    		if h.migrateTarget != nil {
    			return h.migrateTarget.Send(ctx, entry)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer.go

    // If block is false, Read and Write will return ErrIsEmpty or ErrIsFull immediately.
    // By default, the ring buffer is not blocking.
    // This setting should be called before any Read or Write operation or after a Reset.
    func (r *RingBuffer) SetBlocking(block bool) *RingBuffer {
    	r.block = block
    	if block {
    		r.readCond = sync.NewCond(&r.mu)
    		r.writeCond = sync.NewCond(&r.mu)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/DiscreteDomain.java

      private DiscreteDomain(boolean supportsFastOffset) {
        this.supportsFastOffset = supportsFastOffset;
      }
    
      /**
       * Returns, conceptually, "origin + distance", or equivalently, the result of calling {@link
       * #next} on {@code origin} {@code distance} times.
       */
      C offset(C origin, long distance) {
        C current = origin;
        checkNonnegative(distance, "distance");
        for (long i = 0; i < distance; i++) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          function = null;
        }
    
        /*
         * If set()/setValue() throws an Error, we let it propagate. Why? The most likely Error is a
         * StackOverflowError (from deep transform(..., directExecutor()) nesting), and calling
         * setException(stackOverflowError) would fail:
         *
         * - If the stack overflowed before set()/setValue() could even store the result in the output
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. docs/en/docs/deployment/manually.md

    ## ASGI Servers
    
    Let's go a little deeper into the details.
    
    FastAPI uses a standard for building Python web frameworks and servers called <abbr title="Asynchronous Server Gateway Interface">ASGI</abbr>. FastAPI is an ASGI web framework.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Aug 25 02:44:06 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  6. docs/sts/README.md

      }
    }
    ```
    
    > NOTE: You can use the `-cscopes` parameter to restrict the requested scopes, for example to `"openid,policy_role_attribute"`, being `policy_role_attribute` a client_scope / client_mapper that maps a role attribute called policy to a `policy` claim returned by Keycloak.
    
    These credentials can now be used to perform MinIO API operations.
    
    ### Using MinIO Console
    
    - Open MinIO URL on the browser, lets say <http://localhost:9000/>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  7. docs/en/docs/js/termynal.js

                line.textContent = `${chars.slice(0, i)} ${percent}%`;
    			if (percent>progressPercent) {
    				break;
    			}
            }
        }
    
        /**
         * Helper function for animation delays, called with `await`.
         * @param {number} time - Timeout, in ms.
         */
        _wait(time) {
            return new Promise(resolve => setTimeout(resolve, time));
        }
    
        /**
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu May 12 00:06:16 UTC 2022
    - 9.3K bytes
    - Viewed (0)
  8. src/archive/tar/common.go

    	// "SCHILY.xattr." namespace.
    	//
    	// The following are semantically equivalent:
    	//  h.Xattrs[key] = value
    	//  h.PAXRecords["SCHILY.xattr."+key] = value
    	//
    	// When Writer.WriteHeader is called, the contents of Xattrs will take
    	// precedence over those in PAXRecords.
    	//
    	// Deprecated: Use PAXRecords instead.
    	Xattrs map[string]string
    
    	// PAXRecords is a map of PAX extended header records.
    	//
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 13 21:03:27 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java

      }
    
      @CollectionFeature.Require(absent = SUPPORTS_REMOVE)
      public void testSetCount_negative_removeUnsupported() {
        try {
          setCountNoCheckReturnValue(e3(), -1);
          fail(
              "calling setCount() with a negative count should throw "
                  + "IllegalArgumentException or UnsupportedOperationException");
        } catch (IllegalArgumentException | UnsupportedOperationException expected) {
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 13K bytes
    - Viewed (0)
  10. docs/lambda/README.md

     * Running on http://127.0.0.1:5000
    Press CTRL+C to quit
    ```
    
    ## Start MinIO with Lambda target
    
    Register MinIO with a Lambda function, we are calling our target name as `function`, but you may call it any other friendly name of your choice.
    ```
    MINIO_LAMBDA_WEBHOOK_ENABLE_function=on MINIO_LAMBDA_WEBHOOK_ENDPOINT_function=http://localhost:5000 minio server /data &
    ...
    ...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Apr 04 19:15:28 UTC 2023
    - 7.6K bytes
    - Viewed (0)
Back to top