- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 810 for error (0.24 sec)
-
internal/dsync/dsync-server_test.go
func getLockArgs(r *http.Request) (args LockArgs, err error) { buf, err := io.ReadAll(r.Body) if err != nil { return args, err } _, err = args.UnmarshalMsg(buf) return args, err } type lockServerHandler struct { lsrv *lockServer } func (lh *lockServerHandler) writeErrorResponse(w http.ResponseWriter, err error) { w.WriteHeader(http.StatusForbidden) w.Write([]byte(err.Error())) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
cmd/object-api-input-checks.go
) // Checks on CopyObject arguments, bucket and object. func checkCopyObjArgs(ctx context.Context, bucket, object string) error { return checkBucketAndObjectNames(ctx, bucket, object) } // Checks on GetObject arguments, bucket and object. func checkGetObjArgs(ctx context.Context, bucket, object string) error { return checkBucketAndObjectNames(ctx, bucket, object) } // Checks on DeleteObject arguments, bucket and object.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.7K bytes - Viewed (0) -
internal/s3select/sql/record.go
} // Record - is a type containing columns and their values. type Record interface { Get(name string) (*Value, error) // Set a value. // Can return a different record type. Set(name string, value *Value) (Record, error) WriteCSV(writer io.Writer, opts WriteCSVOpts) error WriteJSON(writer io.Writer) error // Clone the record and if possible use the destination provided. Clone(dst Record) Record Reset()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.4K bytes - Viewed (0) -
cmd/object_api_suite_test.go
if err == nil { t.Fatal("Expected error but found nil") } if err.Error() != "Bucket not found: bucket1" { t.Errorf("%s: Expected the error msg to be `%s`, but instead found `%s`", instanceType, "Bucket not found: bucket1", err.Error()) } } // Wrapper for calling testBucketRecreateFails for both Erasure and FS.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
if !mountPointsEqual(mounts[1], mp) { t.Errorf("got unexpected mountInfo[1]: %#v", mounts[1]) } mp = mountInfo{"/dev/2", "/path/to/2", "type2", []string{"flags", "1", "2=3"}, "2", "2"} if !mountPointsEqual(mounts[2], mp) { t.Errorf("got unexpected mountInfo[2]: %#v", mounts[2]) } } // Error cases where parsing fails with invalid Freq and Pass params. { errorCases := []string{
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.3K bytes - Viewed (0) -
internal/event/config.go
func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error { if filter.isEmpty() { return nil } type filterRuleWrapper FilterRule return e.EncodeElement(filterRuleWrapper(filter), start) } // UnmarshalXML - decodes XML data. func (filter *FilterRule) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { // Make subtype to avoid recursive UnmarshalXML(). type filterRule FilterRule
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 8.4K bytes - Viewed (0) -
internal/config/crypto.go
func Decrypt(k kms.KMS, ciphertext io.Reader, context kms.Context) (io.Reader, error) { const ( MaxMetadataSize = 1 << 20 // max. size of the metadata Version = 1 ) var header [5]byte if _, err := io.ReadFull(ciphertext, header[:]); err != nil { return nil, err } if header[0] != Version { return nil, fmt.Errorf("config: unknown ciphertext version %d", header[0]) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 4.8K bytes - Viewed (0) -
cmd/batch-replicate_gen_test.go
} vn := BatchJobReplicateCredentials{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodeBatchJobReplicateCredentials(b *testing.B) { v := BatchJobReplicateCredentials{} var buf bytes.Buffer
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Aug 29 18:27:23 GMT 2023 - 14.2K bytes - Viewed (1) -
internal/auth/credentials_test.go
if err != nil { if testCase.expectedErr == nil { t.Fatalf("test %v: error: expected = <nil>, got = %v", i+1, err) } if testCase.expectedErr.Error() != err.Error() { t.Fatalf("test %v: error: expected = %v, got = %v", i+1, testCase.expectedErr, err) } } else { if testCase.expectedErr != nil { t.Fatalf("test %v: error: expected = %v, got = <nil>", i+1, testCase.expectedErr) } if !cred.IsValid() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/event/target/nats.go
} } if connErr != nil { if connErr.Error() == nats.ErrNoServers.Error() { return false, store.ErrNotConnected } return false, connErr } if target.natsConn != nil && target.args.JetStream.Enable { target.jstream, connErr = target.natsConn.JetStream() if connErr != nil { if connErr.Error() == nats.ErrNoServers.Error() { return false, store.ErrNotConnected }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0)