- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 102 for Barray (0.13 sec)
-
cmd/xl-storage.go
s.Unlock() } volumeDir, err := s.getVolDir(volume) if err != nil { return err } return s.writeAll(ctx, volume, path, b, true, volumeDir) } // AppendFile - append a byte array at path, if file doesn't exist at // path this call explicitly creates it. func (s *xlStorage) AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error) { volumeDir, err := s.getVolDir(volume)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/storagemetric_string.go
// Code generated by "stringer -type=storageMetric -trimprefix=storageMetric xl-storage-disk-id-check.go"; DO NOT EDIT. package cmd import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[storageMetricMakeVolBulk-0] _ = x[storageMetricMakeVol-1] _ = x[storageMetricListVols-2]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Dec 01 20:10:54 GMT 2022 - 2K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient.go
) // newCNIClient is a unit test override variable for mocking. var newCNIClient = buildClient // An udsCore write entries to an UDS server with HTTP Post. Log messages will be encoded into a JSON array. type CNIEventClient struct { client *http.Client url string } func buildClient(address, path string) CNIEventClient { c := &http.Client{ Transport: &http.Transport{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
callbacks/create.go
} insertID += schema.DefaultAutoIncrementIncrement } default: if pkField == nil { return } switch db.Statement.ReflectValue.Kind() { case reflect.Slice, reflect.Array: if config.LastInsertIDReversed { for i := db.Statement.ReflectValue.Len() - 1; i >= 0; i-- { rv := db.Statement.ReflectValue.Index(i) if reflect.Indirect(rv).Kind() != reflect.Struct { break
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 08 03:29:55 GMT 2024 - 12.5K bytes - Viewed (0) -
internal/grid/handlers_string.go
// Code generated by "stringer -type=HandlerID -output=handlers_string.go -trimprefix=Handler msg.go handlers.go"; DO NOT EDIT. package grid import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[handlerInvalid-0] _ = x[HandlerLockLock-1] _ = x[HandlerLockRLock-2] _ = x[HandlerLockUnlock-3]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/grid/msg_gen.go
if err != nil { err = msgp.WrapError(err, "Payload") return } return } // EncodeMsg implements msgp.Encodable func (z *message) EncodeMsg(en *msgp.Writer) (err error) { // array header, size 7 err = en.Append(0x97) if err != nil { return } err = en.WriteUint64(z.MuxID) if err != nil { err = msgp.WrapError(err, "MuxID") return } err = en.WriteUint32(z.Seq)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 18.8K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
if se == nil { return v, nil } var value interface{} switch val := v.(type) { case []byte: // TODO: only strings are supported in s3select output (not // binary arrays) - perhaps we need to check the annotation to // ensure it's UTF8 encoded. value = string(val) case [12]byte: // TODO: This is returned for the parquet INT96 type. We just
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
// It MUST contain the OAuth 2.0 client_id of the Relying Party // as an audience value. It MAY also contain identifiers for // other audiences. In the general case, the aud value is an // array of case sensitive strings. In the common special case // when there is one audience, the aud value MAY be a single // case sensitive audValues, ok := policy.GetValuesFromClaims(claims, audClaim) if !ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 8.3K bytes - Viewed (5) -
finisher_api.go
func (db *DB) CreateInBatches(value interface{}, batchSize int) (tx *DB) { reflectValue := reflect.Indirect(reflect.ValueOf(value)) switch reflectValue.Kind() { case reflect.Slice, reflect.Array: var rowsAffected int64 tx = db.getInstance() // the reflection length judgment of the optimized value reflectLen := reflectValue.Len() callFc := func(tx *DB) error {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 22.7K bytes - Viewed (0) -
cmd/signature-v4-utils.go
} if _, ok := claims[policy.SessionPolicyName]; ok { owner = false } return cred, owner, ErrNone } // sumHMAC calculate hmac between two input byte array. func sumHMAC(key []byte, data []byte) []byte { hash := hmac.New(sha256.New, key) hash.Write(data) return hash.Sum(nil) } // extractSignedHeaders extract signed headers from Authorization header
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0)