- Sort Score
- Result 10 results
- Languages All
Results 981 - 990 of 1,675 for ERROR (0.02 sec)
-
internal/http/check_port_linux.go
// It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{ Control: func(network, address string, c syscall.RawConn) error { c.Control(func(fdPtr uintptr) { if opts.Interface != "" { // When interface is specified look for specifically port availability on
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.9K bytes - Viewed (0) -
internal/disk/stat_openbsd.go
package disk import ( "errors" "fmt" "syscall" ) // GetInfo returns total and free bytes available in a directory, e.g. `/`. func GetInfo(path string, _ bool) (info Info, err error) { s := syscall.Statfs_t{} err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := uint64(s.F_bfree) - uint64(s.F_bavail) info = Info{
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Feb 26 19:34:50 UTC 2024 - 1.8K bytes - Viewed (0) -
cmd/signature-v2.go
return cred, ErrSignatureDoesNotMatch } return cred, ErrNone } // Escape encodedQuery string into unescaped list of query params, returns error // if any while unescaping the values. func unescapeQueries(encodedQuery string) (unescapedQueries []string, err error) { for _, query := range strings.Split(encodedQuery, "&") { var unescapedQuery string unescapedQuery, err = url.QueryUnescape(query) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 12.2K bytes - Viewed (0) -
internal/store/batch_test.go
} var limit uint32 = 100 batch := NewBatch[TestItem](BatchConfig[TestItem]{ Limit: limit, Store: store, CommitTimeout: 5 * time.Minute, Log: func(ctx context.Context, err error, id string, errKind ...interface{}) { t.Log(err) }, }) defer batch.Close() for i := 0; i < int(limit); i++ { if err := batch.Add(testItem); err != nil { t.Fatalf("failed to add %v; %v", i, err)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 5.6K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
p, err := pluginServer.getPodWithRetry(log, "fake", pod.Namespace) assert.Error(t, err) assert.Equal(t, p, nil) }) t.Run("pod out of ambient", func(t *testing.T) { p, err := pluginServer.getPodWithRetry(log, podOutOfAmbient.Name, pod.Namespace) assert.Error(t, err) assert.Equal(t, true, strings.Contains(err.Error(), "unexpectedly not enrolled in ambient")) assert.Equal(t, p, nil) }) }
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 7.6K bytes - Viewed (0) -
internal/config/notify/parse.go
} if err != nil { return fmt.Errorf("error (%s): %w", target.ID(), err) } } else { // Just for call init. // Ignore target is online or offline _, _ = target.IsActive() } } return nil } func fetchSubSysTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) (targets []event.Target, err error) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 47K bytes - Viewed (0) -
istioctl/pkg/tag/generate.go
UserManaged bool } // Generate generates the manifests for a revision tag pointed the given revision. func Generate(ctx context.Context, client kube.Client, opts *GenerateOptions, istioNS string) (string, error) { // abort if there exists a revision with the target tag name revWebhookCollisions, err := GetWebhooksWithRevision(ctx, client.Kube(), opts.Tag) if err != nil { return "", err }
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/bootstrap-peer-server_gen_test.go
} vn := ServerSystemConfig{} 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 BenchmarkEncodeServerSystemConfig(b *testing.B) { v := ServerSystemConfig{} var buf bytes.Buffer msgp.Encode(&buf, &v)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jan 24 21:36:44 UTC 2024 - 2.4K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v2.go
package main import ( "errors" "fmt" "io" "os" "github.com/minio/madmin-go/v3/estream" ) type keepFileErr struct { error } func extractInspectV2(pk []byte, r io.Reader, w io.Writer, okMsg string) error { privKey, err := bytesToPrivateKey(pk) if err != nil { return fmt.Errorf("decoding key returned: %w", err) } sr, err := estream.NewReader(r) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Apr 11 21:22:47 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/bucket-metadata_gen_test.go
t.Log("WARNING: TestEncodeDecodeBucketMetadata Msgsize() is inaccurate") } vn := BucketMetadata{} 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 BenchmarkEncodeBucketMetadata(b *testing.B) { v := BucketMetadata{} var buf bytes.Buffer msgp.Encode(&buf, &v)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 2.3K bytes - Viewed (0)