Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 78 of 78 for NewWriter (0.05 sec)

  1. cmd/notification.go

    func (sys *NotificationSys) DownloadProfilingData(ctx context.Context, writer io.Writer) (profilingDataFound bool) {
    	// Initialize a zip writer which will provide a zipped content
    	// of profiling data of all nodes
    	zipWriter := zip.NewWriter(writer)
    	defer zipWriter.Close()
    
    	// Start by embedding cluster info.
    	if b := getClusterMetaInfo(ctx); len(b) > 0 {
    		internalLogIf(ctx, embedFileInZip(zipWriter, "cluster.info", b, 0o600))
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  2. api/go1.5.txt

    pkg mime, type WordDecoder struct, CharsetReader func(string, io.Reader) (io.Reader, error)
    pkg mime, type WordEncoder uint8
    pkg mime/quotedprintable, func NewReader(io.Reader) *Reader
    pkg mime/quotedprintable, func NewWriter(io.Writer) *Writer
    pkg mime/quotedprintable, method (*Reader) Read([]uint8) (int, error)
    pkg mime/quotedprintable, method (*Writer) Close() error
    pkg mime/quotedprintable, method (*Writer) Write([]uint8) (int, error)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Jul 30 21:14:09 UTC 2015
    - 46.6K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    		go func() {
    			// Initialize MRF meta header.
    			var data [4]byte
    			binary.LittleEndian.PutUint16(data[0:2], mrfMetaFormat)
    			binary.LittleEndian.PutUint16(data[2:4], mrfMetaVersion)
    			mw := msgp.NewWriter(w)
    			n, err := mw.Write(data[:])
    			if err != nil {
    				w.CloseWithError(err)
    				return
    			}
    			if n != len(data) {
    				w.CloseWithError(io.ErrShortWrite)
    				return
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    	// Initialize a zip writer which will provide a zipped content
    	// of bucket metadata
    	zipWriter := zip.NewWriter(w)
    	defer zipWriter.Close()
    	rawDataFn := func(r io.Reader, filename string, sz int) error {
    		header, zerr := zip.FileInfoHeader(dummyFileInfo{
    			name:    filename,
    			size:    int64(sz),
    			mode:    0o600,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
  5. cmd/sts-handlers_test.go

    	}
    	exportContent := map[string][]byte{}
    	for k, v := range exportContentStrings {
    		exportContent[k] = []byte(v)
    	}
    
    	var importContent []byte
    	{
    		var b bytes.Buffer
    		zipWriter := zip.NewWriter(&b)
    		rawDataFn := func(r io.Reader, filename string, sz int) error {
    			header, zerr := zip.FileInfoHeader(dummyFileInfo{
    				name:    filename,
    				size:    int64(sz),
    				mode:    0o600,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 100.2K bytes
    - Viewed (1)
  6. api/go1.txt

    pkg archive/tar, const TypeSymlink ideal-char
    pkg archive/tar, const TypeXGlobalHeader ideal-char
    pkg archive/tar, const TypeXHeader ideal-char
    pkg archive/tar, func NewReader(io.Reader) *Reader
    pkg archive/tar, func NewWriter(io.Writer) *Writer
    pkg archive/tar, method (*Reader) Next() (*Header, error)
    pkg archive/tar, method (*Reader) Read([]uint8) (int, error)
    pkg archive/tar, method (*Writer) Close() error
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SearchHelper.java

            for (final SearchRequestParamsRewriter rewriter : searchRequestParamsRewriters) {
                newParams = rewriter.rewrite(newParams);
            }
            return newParams;
        }
    
        /**
         * Adds a search request parameter rewriter to the list of active rewriters.
         *
         * @param rewriter The parameter rewriter to add
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 35.8K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/helper/SearchHelperTest.java

            assertEquals("ja", result[1].getValues()[1]);
        }
    
        // Test addRewriter method
        public void test_addRewriter() {
            SearchHelper.SearchRequestParamsRewriter rewriter = p -> p;
    
            searchHelper.addRewriter(rewriter);
    
            assertNotNull(searchHelper.searchRequestParamsRewriters);
            assertTrue(searchHelper.searchRequestParamsRewriters.length > 0);
        }
    
        // Test getLanguages method
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 19 23:49:30 UTC 2025
    - 18.9K bytes
    - Viewed (0)
Back to top