Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 198 for channel1 (0.06 seconds)

  1. internal/event/target/elasticsearch.go

    	err := target.checkAndInitClient(ctx)
    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  2. src/cmd/cgo/doc.go

    (which implies that it may not return a string, slice, channel, and so
    forth). A Go function called by C code may take C pointers as arguments,
    and it may store non-pointer data, C pointers, or Go pointers to pinned
    memory through those pointers. It may not store a Go pointer to unpinned
    memory in memory pointed to by a C pointer (which again, implies that it
    may not store a string, slice, channel, and so forth). A Go function
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 08 22:37:14 GMT 2025
    - 43.9K bytes
    - Click Count (0)
  3. docs/ko/docs/deployment/manually.md

    다음을 포함해 여러 대안이 있습니다:
    
    * [Uvicorn](https://www.uvicorn.dev/): 고성능 ASGI 서버.
    * [Hypercorn](https://hypercorn.readthedocs.io/): HTTP/2 및 Trio 등 여러 기능과 호환되는 ASGI 서버.
    * [Daphne](https://github.com/django/daphne): Django Channels를 위해 만들어진 ASGI 서버.
    * [Granian](https://github.com/emmett-framework/granian): Python 애플리케이션을 위한 Rust HTTP 서버.
    * [NGINX Unit](https://unit.nginx.org/howto/fastapi/): NGINX Unit은 가볍고 다용도로 사용할 수 있는 웹 애플리케이션 런타임입니다.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:06:26 GMT 2026
    - 7.4K bytes
    - Click Count (0)
  4. internal/rest/client.go

    		c.dumpHTTP(req, resp)
    	}
    
    	if resp.StatusCode != http.StatusOK {
    		// If server returns 412 pre-condition failed, it would
    		// mean that authentication succeeded, but another
    		// side-channel check has failed, we shall take
    		// the client offline in such situations.
    		// generally all implementations should simply return
    		// 403, but in situations where there is a dependency
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/io/FilesTest.java

    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.PrintWriter;
    import java.io.RandomAccessFile;
    import java.nio.ByteBuffer;
    import java.nio.MappedByteBuffer;
    import java.nio.channels.FileChannel.MapMode;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Random;
    import junit.framework.TestSuite;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  6. cmd/metacache-set.go

    		return triggerExpiryAndRepl(ctx, *o, entry)
    	}
    	return false
    }
    
    // gatherResults will collect all results on the input channel and filter results according
    // to the options or to the current bucket ILM expiry rules.
    // Caller should close the channel when done.
    // The returned function will return the results once there is enough or input is closed,
    // or the context is canceled.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.7K bytes
    - Click Count (0)
  7. cmd/data-usage-cache.go

    	// should skip healing the disk
    	SkipHealing bool
    
    	// Active lifecycle, if any on the bucket
    	lifeCycle *lifecycle.Lifecycle `msg:"-"`
    
    	// optional updates channel.
    	// If set updates will be sent regularly to this channel.
    	// Will not be closed when returned.
    	updates     chan<- dataUsageEntry `msg:"-"`
    	replication replicationConfig     `msg:"-"`
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb2/io/Smb2WriteRequestTest.java

                assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, headerStart + 16, headerStart + 32)); // File ID
                assertEquals(0, SMBUtil.readInt4(buffer, headerStart + 32)); // Channel
                assertEquals(500, SMBUtil.readInt4(buffer, headerStart + 36)); // Remaining bytes
                assertEquals(0, SMBUtil.readInt2(buffer, headerStart + 40)); // WriteChannelInfoOffset
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  9. internal/s3select/jstream/decoder.go

    // containing those values is emitted.
    func (d *Decoder) Recursive() *Decoder {
    	d.emitRecursive = true
    	return d
    }
    
    // Stream begins decoding from the underlying reader and returns a
    // streaming MetaValue channel for JSON values at the configured emitDepth.
    func (d *Decoder) Stream() chan *MetaValue {
    	go d.decode()
    	return d.metaCh
    }
    
    // Pos returns the number of bytes consumed from the underlying reader
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  10. CONTRIBUTING.md

    If you use AI tools when contributing to Gradle, please review our [AI Policy](AI_POLICY.md).
    
    ### Additional help
    
    If you run into any trouble, please reach out to us on the issue you are working on.
    There is a `#contributing` channel on the community Slack which you can use
    to ask any questions.
    
    ## Finding issues to work on
    
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Mar 27 18:43:39 GMT 2026
    - 19.1K bytes
    - Click Count (0)
Back to Top