Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 948 for makes (0.02 seconds)

  1. internal/event/target/amqp.go

    	target.connMutex.Lock()
    	defer target.connMutex.Unlock()
    
    	if target.conn != nil {
    		ch, err = target.conn.Channel()
    		if err == nil {
    			if target.args.PublisherConfirms {
    				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
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  2. docs/en/docs/reference/dependencies.md

    # Dependencies - `Depends()` and `Security()`
    
    ## `Depends()`
    
    Dependencies are handled mainly with the special function `Depends()` that takes a callable.
    
    Here is the reference for it and its parameters.
    
    You can import it directly from `fastapi`:
    
    ```python
    from fastapi import Depends
    ```
    
    ::: fastapi.Depends
    
    ## `Security()`
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 671 bytes
    - Click Count (0)
  3. internal/grid/grid.go

    	defaultSingleRequestTimeout = time.Minute
    )
    
    var internalByteBuffer = bpool.Pool[*[]byte]{
    	New: func() *[]byte {
    		m := make([]byte, 0, defaultBufferSize)
    		return &m
    	},
    }
    
    var internal32KByteBuffer = bpool.Pool[*[]byte]{
    	New: func() *[]byte {
    		m := make([]byte, 0, biggerBufMin)
    		return &m
    	},
    }
    
    // GetByteBuffer can be replaced with a function that returns a small
    // byte buffer.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7K bytes
    - Click Count (0)
  4. cmd/bitrot.go

    			logger.Fatal(errSelfTestFailure, fmt.Sprintf("bitrot: failed to decode %v checksum %s for selftest: %v", algorithm, checksums[algorithm], err))
    		}
    		var (
    			hash = algorithm.New()
    			msg  = make([]byte, 0, hash.Size()*hash.BlockSize())
    			sum  = make([]byte, 0, hash.Size())
    		)
    		for i := 0; i < hash.Size()*hash.BlockSize(); i += hash.Size() {
    			hash.Write(msg)
    			sum = hash.Sum(sum[:0])
    			msg = append(msg, sum...)
    			hash.Reset()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  5. internal/http/dial_dnscache.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"time"
    )
    
    // LookupHost is a function to make custom lookupHost for optional cached DNS requests
    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  6. internal/event/rules.go

    			targetIDs = targetIDs.Union(targetIDSet)
    		}
    	}
    
    	return targetIDs
    }
    
    // Clone - returns copy of this rules.
    func (rules Rules) Clone() Rules {
    	rulesCopy := make(Rules)
    
    	for pattern, targetIDSet := range rules {
    		rulesCopy[pattern] = targetIDSet.Clone()
    	}
    
    	return rulesCopy
    }
    
    // Union - returns union with given rules as new rules.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  7. internal/s3select/jstream/decoder.go

    func NewDecoder(r io.Reader, emitDepth int) *Decoder {
    	d := &Decoder{
    		scanner:   newScanner(r),
    		emitDepth: emitDepth,
    		scratch:   &scratch{data: make([]byte, 1024)},
    		metaCh:    make(chan *MetaValue, 128),
    	}
    	if emitDepth < 0 {
    		d.emitDepth = 0
    		d.emitRecursive = true
    	}
    	return d
    }
    
    // ObjectAsKVS - by default JSON returns map[string]interface{} this
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  8. cmd/bucket-handlers.go

    	postPolicyBucketTagging = "tagging"
    )
    
    // Check if there are buckets on server without corresponding entry in etcd backend and
    // make entries. Here is the general flow
    // - Range over all the available buckets
    // - Check if a bucket has an entry in etcd backend
    // -- If no, make an entry
    // -- If yes, check if the entry matches local IP check if we
    //
    //	need to update the entry then proceed to update
    //
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  9. src/bufio/export_test.go

    )
    
    var IsSpace = isSpace
    
    const DefaultBufSize = defaultBufSize
    
    func (s *Scanner) MaxTokenSize(n int) {
    	if n < utf8.UTFMax || n > 1e9 {
    		panic("bad max token size")
    	}
    	if n < len(s.buf) {
    		s.buf = make([]byte, n)
    	}
    	s.maxTokenSize = n
    }
    
    // ErrOrEOF is like Err, but returns EOF. Used to test a corner case.
    func (s *Scanner) ErrOrEOF() error {
    	return s.err
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Nov 02 17:17:44 GMT 2017
    - 597 bytes
    - Click Count (0)
  10. api/maven-api-core/src/main/java/org/apache/maven/api/services/Interpolator.java

        }
    
        /**
         * Memoizes a given function that takes a String input and produces a String output.
         * This method creates a new function that caches the results of the original function,
         * improving performance for repeated calls with the same input.
         *
         * @param callback The original function to be memoized. It takes a String as input and returns a String.
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Jan 13 16:14:35 GMT 2025
    - 6.9K bytes
    - Click Count (0)
Back to Top