- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,101 for errored (0.4 sec)
-
internal/logger/target/kafka/kafka_scram_client_contrib.go
// error if the server message is invalid. Calling Step after a conversation // completes is also an error. func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) { response, err = x.ClientConversation.Step(challenge) return } // Done returns true if the conversation is completed or has errored. func (x *XDGSCRAMClient) Done() bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.3K bytes - Viewed (1) -
cni/pkg/plugin/plugin_test.go
conf, err := parseConfig(args.StdinData) if err != nil { t.Fatalf("config parse failed with error: %v", err) } // Create a kube client client := kube.NewFakeClient(objects...) mockRedir := &mockInterceptRuleMgr{} err = doAddRun(args, conf, client.Kube(), mockRedir) if err != nil { t.Fatalf("failed with error: %v", err) } return mockRedir }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
internal/event/target/kafka_scram_client_contrib.go
// error if the server message is invalid. Calling Step after a conversation // completes is also an error. func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) { response, err = x.ClientConversation.Step(challenge) return } // Done returns true if the conversation is completed or has errored. func (x *XDGSCRAMClient) Done() bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/erasure-object.go
// // errs: errors from reading xl.meta in all disks // err: reduced errs // bucket: the object name in question func shouldCheckForDangling(err error, errs []error, bucket string) bool { // Avoid data in .minio.sys for now if bucket == minioMetaBucket { return false } switch { // Check if we have a read quorum issue case errors.Is(err, errErasureReadQuorum): return true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/metacache-set.go
// if disk did not return any result, but also haven't errored // the entry will be empty and errs will partial func(entries metaCacheEntries, errs []error) // finished will be called when all streams have finished and // more than one disk returned an error. // Will not be called if everything operates as expected. finished func(errs []error) } // listPathRaw will list a path on the provided drives.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
internal/s3select/errors.go
package s3select import "strings" // SelectError - represents s3 select error specified in // https://docs.aws.amazon.com/AmazonS3/latest/API/RESTObjectSELECTContent.html#RESTObjectSELECTContent-responses-special-errors. type SelectError interface { Cause() error ErrorCode() string ErrorMessage() string HTTPStatusCode() int Error() string } type s3Error struct { code string message string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 14 16:48:36 GMT 2022 - 4.3K bytes - Viewed (0) -
internal/bucket/lifecycle/error.go
package lifecycle import ( "fmt" ) // Error is the generic type for any error happening during tag // parsing. type Error struct { err error } // Errorf - formats according to a format specifier and returns // the string as a value that satisfies error of type tagging.Error func Errorf(format string, a ...interface{}) error { return Error{err: fmt.Errorf(format, a...)} } // Unwrap the internal error.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.3K bytes - Viewed (0) -
cni/pkg/nodeagent/error.go
package nodeagent import ( "errors" "fmt" ) var ErrPartialAdd = errors.New("partial add error") type PartialAddError struct { inner error } func (e *PartialAddError) Error() string { return fmt.Sprintf("%s: %v", ErrPartialAdd.Error(), e.inner) } func (e *PartialAddError) Unwrap() []error { return []error{ErrPartialAdd, e.inner} }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1K bytes - Viewed (0) -
cmd/api-errors_test.go
// Check if an API error is properly defined func TestAPIErrCodeDefinition(t *testing.T) { for errAPI := ErrNone + 1; errAPI < apiErrCodeEnd; errAPI++ { errCode, ok := errorCodes[errAPI] if !ok { t.Fatal(errAPI, "error code is not defined in the API error code table") } if errCode.Code == "" { t.Fatal(errAPI, "error code has an empty XML code") } if errCode.HTTPStatusCode == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 25 15:13:08 GMT 2023 - 3.4K bytes - Viewed (0) -
cmd/typed-errors.go
// error returned when temporary account is not found var errNoSuchTempAccount = errors.New("Specified temporary account does not exist") // error returned in IAM subsystem when an account doesn't exist. var errNoSuchAccount = errors.New("Specified account does not exist") // error returned in IAM subsystem when groups doesn't exist.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0)