Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 461 - 470 of 598 for readOp (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/bytes/example_test.go

    	b.Write([]byte("Hello "))
    	fmt.Fprintf(&b, "world!")
    	b.WriteTo(os.Stdout)
    	// Output: Hello world!
    }
    
    func ExampleBuffer_reader() {
    	// A Buffer can turn a string or a []byte into an io.Reader.
    	buf := bytes.NewBufferString("R29waGVycyBydWxlIQ==")
    	dec := base64.NewDecoder(base64.StdEncoding, buf)
    	io.Copy(os.Stdout, dec)
    	// Output: Gophers rule!
    }
    
    func ExampleBuffer_Bytes() {
    	buf := bytes.Buffer{}
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon May 12 16:07:54 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  2. impl/maven-core/src/main/java/org/apache/maven/ReactorReader.java

    import org.eclipse.aether.repository.WorkspaceRepository;
    import org.eclipse.aether.util.artifact.ArtifactIdUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /**
     * An implementation of a workspace reader that knows how to search the Maven reactor for artifacts, either as packaged
     * jar if it has been built, or only compile output directory if packaging hasn't happened yet.
     *
     */
    @Named(ReactorReader.HINT)
    @SessionScoped
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Dec 15 11:20:38 GMT 2025
    - 24.4K bytes
    - Click Count (0)
  3. cmd/admin-handlers-site-replication.go

    	if err := json.NewEncoder(w).Encode(idpSettings); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    func parseJSONBody(ctx context.Context, body io.Reader, v any, encryptionKey string) error {
    	data, err := io.ReadAll(body)
    	if err != nil {
    		return SRError{
    			Cause: err,
    			Code:  ErrSiteReplicationInvalidRequest,
    		}
    	}
    	if encryptionKey != "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  4. cmd/metacache-set_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package cmd
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *listPathOptions) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.8K bytes
    - Click Count (0)
  5. api/go1.6.txt

    pkg math/big, method (*Float) UnmarshalText([]uint8) error
    pkg math/big, method (*Int) Append([]uint8, int) []uint8
    pkg math/big, method (*Int) Text(int) string
    pkg math/rand, func Read([]uint8) (int, error)
    pkg math/rand, method (*Rand) Read([]uint8) (int, error)
    pkg net, type DNSError struct, IsTemporary bool
    pkg net, type Dialer struct, Cancel <-chan struct
    pkg net/http, const MethodConnect = "CONNECT"
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Jan 13 23:40:13 GMT 2016
    - 12.9K bytes
    - Click Count (0)
  6. TESTING.asciidoc

    operations to be executed and the obtained results that need to be tested.
    
    The YAML tests support various operators defined in the link:/rest-api-spec/src/yamlRestTest/resources/rest-api-spec/test/README.asciidoc[rest-api-spec] and adhere to the link:/rest-api-spec/README.markdown[Elasticsearch REST API JSON specification]
    In order to run the YAML tests, the relevant API specification needs
    to be on the test classpath. Any gradle project that has support for REST
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Mon Jun 07 13:55:20 GMT 2021
    - 32.5K bytes
    - Click Count (0)
  7. docs/debugging/xl-meta/main.go

    		foundData := make(map[string][]byte)
    		partDataToVerID := make(map[string][2]string)
    		var baseName string
    		// versionID ->
    		combineFiles := make(map[string][]string)
    		decode := func(r io.Reader, file string) ([]byte, error) {
    			file = strings.ReplaceAll(file, ":", "_")
    			b, err := io.ReadAll(r)
    			if err != nil {
    				return nil, err
    			}
    			b, _, minor, err := checkXL2V1(b)
    			if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.4K bytes
    - Click Count (0)
  8. impl/maven-core/plugin-manager.txt

    h3. Plugins
    
    * Execution model
    * Metadata model
    * Metadata tooling
     ** Metadata extractor
     ** Metadata reader
     ** Metadata writer
     ** Metadata adapter (if required for the target system)
    * Maven packaging and lifecycle
    * Maven test harness for plugin execution model
    * Eclipse IDE tooling for plugin execution model and metadata model
    
    - we also seem to have information like the plugin lifecycle model that's buried inside the maven execution model
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jan 22 11:03:29 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  9. cmd/batch-expire.go

    	r.line, r.col = val.Line, val.Column
    	return nil
    }
    
    // Notify notifies notification endpoint if configured regarding job failure or success.
    func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error {
    	if r.NotificationCfg.Endpoint == "" {
    		return nil
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Apr 22 11:16:32 GMT 2025
    - 23K bytes
    - Click Count (0)
  10. internal/dsync/drwmutex.go

    	isReadLock := false
    	return dm.lockBlocking(ctx, cancel, id, source, isReadLock, opts)
    }
    
    // RLock holds a read lock on dm.
    //
    // If one or more read locks are already in use, it will grant another lock.
    // Otherwise the calling go routine blocks until the mutex is available.
    func (dm *DRWMutex) RLock(id, source string) {
    	isReadLock := true
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.3K bytes
    - Click Count (0)
Back to Top