- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for straum (0.17 sec)
-
cmd/metacache-stream.go
"github.com/tinylib/msgp/msgp" "github.com/valyala/bytebufferpool" ) // metadata stream format: // // The stream is s2 compressed. // https://github.com/klauspost/compress/tree/master/s2#s2-compression // This ensures integrity and reduces the size typically by at least 50%. // // All stream elements are msgpack encoded. // // 1 Integer, metacacheStreamVersion of the writer.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
internal/event/target/kafka_scram_client_contrib.go
// each authentication attempt. type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn } // Begin constructs a SCRAM client component based on a given hash.Hash // factory receiver. This constructor will normalize the username, password // and authzID via the SASLprep algorithm, as recommended by RFC-5802. If // SASLprep fails, the method returns an error.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.2K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v2.go
} if extracted { return keepFileErr{fmt.Errorf("next stream: %w", err)} } return fmt.Errorf("next stream: %w", err) } if stream.Name == "inspect.zip" { if extracted { return keepFileErr{errors.New("multiple inspect.zip streams found")} } _, err := io.Copy(w, stream) if err != nil { return fmt.Errorf("reading inspect stream: %w", err) } fmt.Println(okMsg) extracted = true
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
"github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) // Reader - JSON record reader for S3Select. type Reader struct { args *json.ReaderArgs input chan simdjson.Stream decoded chan simdjson.Object // err will only be returned after decoded has been closed. err *error readCloser io.ReadCloser onReaderExit func() exitReader chan struct{}
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/metacache-walk.go
} // supported FS for Nlink optimization in readdir. const ( xfs = "XFS" ext4 = "EXT4" ) // WalkDir will traverse a directory and return all entries found. // On success a sorted meta cache stream will be returned. // Metadata has data stripped, if any. func (s *xlStorage) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) { legacyFS := !(s.fsType == xfs || s.fsType == ext4) s.RLock()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/s3select/csv/args.go
args.QuoteEscapeCharacter = defaultQuoteEscapeCharacter args.CommentCharacter = defaultCommentCharacter args.AllowQuotedRecordDelimiter = false for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { tagName := se.Name.Local switch tagName {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 5.4K bytes - Viewed (0) -
cmd/admin-handlers.go
if publicKey != nil { w.WriteHeader(200) stream := estream.NewWriter(w) defer stream.Close() clusterKey, err := bytesToPublicKey(getSubnetAdminPublicKey()) if err != nil { bugLogIf(ctx, stream.AddError(err.Error())) return } err = stream.AddKeyEncrypted(clusterKey) if err != nil { bugLogIf(ctx, stream.AddError(err.Error())) return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/object-api-utils_test.go
metadata: map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86", "x-amz-storage-class": "STANDARD"}, want: map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86"}, }, { name: "2",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 23.4K bytes - Viewed (0) -
cmd/storage-interface.go
StatVol(ctx context.Context, volume string) (vol VolInfo, err error) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) // WalkDir will walk a directory on disk and return a metacache stream on wr. WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error // Metadata operations DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
internal/s3select/json/preader.go
if !ok { dst = make([]jstream.KVS, 0, 1000) } d := jstream.NewDecoder(bytes.NewBuffer(in.input), 0).ObjectAsKVS() stream := d.Stream() all := dst[:0] for mv := range stream { var kvs jstream.KVS if mv.ValueType == jstream.Object { // This is a JSON object type (that preserves key // order) kvs = mv.Value.(jstream.KVS)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0)