- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 885 for errorea (0.21 sec)
-
cni/pkg/install/install.go
// At that point, the func yields so the caller can recheck the validity of the install. // If an error occurs or context is canceled, the function will return an error. func (in *Installer) sleepWatchInstall(ctx context.Context, installedBinFiles sets.String) error { // Watch our specific binaries, in each configured binary dir. // We may or may not be the only CNI plugin in play, and if we are not
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
cmd.Stderr = &stderr if err := cmd.Start(); err != nil { return nil, fmt.Errorf("idevicedebugserverproxy: %v", err) } go func() { if err := cmd.Wait(); err != nil { if _, ok := err.(*exec.ExitError); ok { errChan <- fmt.Errorf("idevicedebugserverproxy: %s", stderr.Bytes()) } else { errChan <- fmt.Errorf("idevicedebugserverproxy: %v", err) } } errChan <- nil }()
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
internal/event/target/nats.go
} // Validate NATSArgs fields func (n NATSArgs) Validate() error { if !n.Enable { return nil } if n.Address.IsEmpty() { return errors.New("empty address") } if n.Subject == "" { return errors.New("empty subject") } if n.ClientCert != "" && n.ClientKey == "" || n.ClientCert == "" && n.ClientKey != "" { return errors.New("cert and key must be specified as a pair") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/metacache-stream.go
func (w *metacacheWriter) write(objs ...metaCacheEntry) error { if w == nil { return errors.New("metacacheWriter: nil writer") } if len(objs) == 0 { return nil } if w.creator != nil { err := w.creator() w.creator = nil if err != nil { return fmt.Errorf("metacacheWriter: unable to create writer: %w", err) } if w.mw == nil { return errors.New("metacacheWriter: writer not initialized") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/erasure-multipart.go
if !disk.IsOnline() { continue } uploadIDs, err = disk.ListDir(ctx, bucket, minioMetaMultipartBucket, er.getMultipartSHADir(bucket, object), -1) if err != nil { if errors.Is(err, errDiskNotFound) { continue } if errors.Is(err, errFileNotFound) { return result, nil } return result, toObjectErr(err, bucket, object) } break } for i := range uploadIDs {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
schema/schema.go
return ParseWithSpecialTableName(dest, cacheStore, namer, "") } // ParseWithSpecialTableName get data type from dialector with extra schema table func ParseWithSpecialTableName(dest interface{}, cacheStore *sync.Map, namer Namer, specialTableName string) (*Schema, error) { if dest == nil { return nil, fmt.Errorf("%w: %+v", ErrUnsupportedDataType, dest) }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Oct 10 06:50:29 GMT 2023 - 13.7K bytes - Viewed (0) -
internal/event/target/amqp.go
} func (target *AMQPTarget) channel() (*amqp091.Channel, chan amqp091.Confirmation, error) { var err error var conn *amqp091.Connection var ch *amqp091.Channel isAMQPClosedErr := func(err error) bool { if err == amqp091.ErrClosed { return true } if nerr, ok := err.(*net.OpError); ok { return (nerr.Err.Error() == "use of closed network connection") } return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
internal/config/api/api.go
default: return cfg, fmt.Errorf("invalid value %v for list_quorum: will default to 'strict'", listQuorum) } cfg.ListQuorum = listQuorum replicationPriority := env.Get(EnvAPIReplicationPriority, kvs.GetWithDefault(apiReplicationPriority, DefaultKVS)) switch replicationPriority { case "slow", "fast", "auto": default: return cfg, fmt.Errorf("invalid value %v for replication_priority", replicationPriority)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
src/cmd/asm/internal/asm/parse.go
p.errorf("register list: expected ']', found EOF") } else { p.errorf("register list: bad low register in `[%s`", loName) } return } if tok := p.next().ScanToken; tok != '-' { p.errorf("register list: expected '-' after `[%s`, found %s", loName, tok) return } hiName := p.next().String() hi, ok := p.arch.Register[hiName] if !ok {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 36.9K bytes - Viewed (0) -
cmd/postpolicyform.go
func checkPostPolicy(formValues http.Header, postPolicyForm PostPolicyForm) error { // Check if policy document expiry date is still not reached if !postPolicyForm.Expiration.After(UTCNow()) { return fmt.Errorf("Invalid according to Policy: Policy expired") } // check all formValues appear in postPolicyForm or return error. #https://github.com/minio/minio/issues/17391 checkHeader := map[string][]string{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.2K bytes - Viewed (0)