Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 529 for fbytes (0.03 seconds)

  1. internal/pubsub/pubsub.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package pubsub
    
    import (
    	"bytes"
    	"encoding/json"
    	"fmt"
    	"sync"
    	"sync/atomic"
    )
    
    // GetByteBuffer returns a byte buffer from the pool.
    var GetByteBuffer = func() []byte {
    	return make([]byte, 0, 4096)
    }
    
    // Sub - subscriber entity.
    type Sub[T Maskable] struct {
    	ch     chan T
    	types  Mask
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (0)
  2. internal/etag/etag.go

    func (e ETag) IsEncrypted() bool {
    	// An encrypted ETag must be at least 32 bytes long.
    	// It contains the encrypted ETag value + an authentication
    	// code generated by the AEAD cipher.
    	//
    	// Here is an incorrect implementation of IsEncrypted:
    	//
    	//   return len(e) > 16 && !bytes.ContainsRune(e, '-')
    	//
    	// An encrypted ETag may contain some random bytes - e.g.
    	// and nonce value. This nonce value may contain a '-'
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 13.2K bytes
    - Click Count (0)
  3. docs/bucket/versioning/DESIGN.md

    Inline data is optional. If no inline data is present, it is encoded as 0 bytes.
    
    | Entry               | Encoding                    | Content
    | --------------------|-----------------------------|----------------------------------------
    | xlMetaInlineDataVer | byte                        | version identifier
    | id -> data          | msgp `map[string][]byte`      | Map of string id -> byte content
    
    Currently only xlMetaInlineDataVer == 1 exists.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jul 17 15:43:14 GMT 2022
    - 5.8K bytes
    - Click Count (0)
  4. cmd/encryption-v1_test.go

    	},
    	{
    		ObjectKey:  [32]byte{},
    		ObjectInfo: ObjectInfo{ETag: "916516b396f0f4d4f2a0e7177557bec4-738"},
    		ETag:       "916516b396f0f4d4f2a0e7177557bec4-738",
    	},
    	{
    		ObjectKey:  [32]byte{},
    		ObjectInfo: ObjectInfo{ETag: "916516b396f0f4d4f2a0e7177557bec4-Q"},
    		ETag:       "",
    		ShouldFail: true, // Q is not a number
    	},
    	{
    		ObjectKey:  [32]byte{},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  5. internal/grid/connection_test.go

    	// 1: Echo
    	errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("1: server payload: ", len(payload), "bytes.")
    		return append([]byte{}, payload...), nil
    	}))
    	// 2: Return as error
    	errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("2: server payload: ", len(payload), "bytes.")
    		err := RemoteErr(payload)
    		return nil, &err
    	}))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  6. internal/config/policy/opa/config.go

    	CloseRespFn func(r io.ReadCloser) `json:"-"`
    }
    
    // Validate - validate opa configuration params.
    func (a *Args) Validate() error {
    	req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte("")))
    	if err != nil {
    		return err
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    	if a.AuthToken != "" {
    		req.Header.Set("Authorization", a.AuthToken)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  7. internal/ioutil/hardlimitreader.go

    // data returned to just N bytes. Each call to Read
    // updates N to reflect the new amount remaining.
    // Read returns EOF when N <= 0 or when the underlying R returns EOF.
    type HardLimitedReader struct {
    	R io.Reader // underlying reader
    	N int64     // max bytes remaining
    }
    
    func (l *HardLimitedReader) Read(p []byte) (n int, err error) {
    	if l.N < 0 {
    		return 0, ErrOverread
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2K bytes
    - Click Count (0)
  8. cmd/bucket-handlers_test.go

    		}
    		if !bytes.Equal(testCase.locationResponse, rec.Body.Bytes()) && testCase.shouldPass {
    			t.Errorf("Test %d: %s: Expected the response to be `%s`, but instead found `%s`", i+1, instanceType, string(testCase.locationResponse), rec.Body.String())
    		}
    		errorResponse := APIErrorResponse{}
    		err = xml.Unmarshal(rec.Body.Bytes(), &errorResponse)
    		if err != nil && !testCase.shouldPass {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 39.8K bytes
    - Click Count (0)
  9. guava/src/com/google/common/io/Resources.java

        return asByteSource(url).asCharSource(charset);
      }
    
      /**
       * Reads all bytes from a URL into a byte array.
       *
       * @param url the URL to read from
       * @return a byte array containing all the bytes from the URL
       * @throws IOException if an I/O error occurs
       */
      public static byte[] toByteArray(URL url) throws IOException {
        return asByteSource(url).read();
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  10. internal/bucket/encryption/bucket-sse-config_test.go

    			expectedErr: errors.New("MasterKeyID contains unsupported characters"),
    			shouldPass:  false,
    		},
    	}
    
    	for i, tc := range testCases {
    		ssec, err := ParseBucketSSEConfig(bytes.NewReader([]byte(tc.inputXML)))
    		if tc.shouldPass && err != nil {
    			t.Errorf("Test case %d: Expected to succeed but got %s", i+1, err)
    		}
    
    		if !tc.shouldPass {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 16 18:28:30 GMT 2022
    - 6.1K bytes
    - Click Count (0)
Back to Top