- Sort Score
- Result 10 results
- Languages All
Results 591 - 600 of 1,384 for funcs (0.02 sec)
-
internal/disk/directio_unix.go
const ODirectPlatform = true // OpenFileDirectIO - bypass kernel cache. func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) { return directio.OpenFile(filePath, flag, perm) } // DisableDirectIO - disables directio mode. func DisableDirectIO(f *os.File) error { fd := f.Fd() flag, err := unix.FcntlInt(fd, unix.F_GETFL, 0) if err != nil { return err
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 17 14:31:36 UTC 2023 - 1.6K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze_test.go
import ( "strings" "testing" . "github.com/onsi/gomega" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/istioctl/pkg/util/testutil" "istio.io/istio/pkg/config/analysis/diag" ) func TestErrorOnIssuesFound(t *testing.T) { g := NewWithT(t) msgs := []diag.Message{ diag.NewMessage( diag.NewMessageType(diag.Error, "B1", "Template: %q"), nil, "", ), diag.NewMessage(
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 1.8K bytes - Viewed (0) -
clause/update_test.go
package clause_test import ( "fmt" "testing" "gorm.io/gorm/clause" ) func TestUpdate(t *testing.T) { results := []struct { Clauses []clause.Interface Result string Vars []interface{} }{ { []clause.Interface{clause.Update{}}, "UPDATE `users`", nil, }, { []clause.Interface{clause.Update{Modifier: "LOW_PRIORITY"}}, "UPDATE LOW_PRIORITY `users`", nil, }, {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Jun 02 01:18:01 UTC 2020 - 722 bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
addError error delError error } func (f *fakeZtunnel) Run(ctx context.Context) { } func (f *fakeZtunnel) PodDeleted(ctx context.Context, uid string) error { f.deletedPods.Add(1) return f.delError } func (f *fakeZtunnel) PodAdded(ctx context.Context, pod *corev1.Pod, netns Netns) error { f.addedPods.Add(1) return f.addError } func (f *fakeZtunnel) Close() error { return nil }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jun 28 23:33:46 UTC 2024 - 3.9K bytes - Viewed (0) -
src/archive/tar/strconv_test.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package tar import ( "math" "strings" "testing" "time" ) func TestFitsInBase256(t *testing.T) { vectors := []struct { in int64 width int ok bool }{ {+1, 8, true}, {0, 8, true}, {-1, 8, true}, {1 << 56, 8, false}, {(1 << 56) - 1, 8, true},
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Feb 09 05:28:50 UTC 2021 - 14K bytes - Viewed (0) -
internal/etag/etag_test.go
}, } func TestDecrypt(t *testing.T) { for i, test := range decryptTests { etag, err := Decrypt(test.Key, test.ETag) if err != nil { t.Fatalf("Test %d: failed to decrypt ETag: %v", i, err) } if !Equal(etag, test.Plaintext) { t.Fatalf("Test %d: got '%v' - want '%v'", i, etag, test.Plaintext) } } } func must(s string) ETag { t, err := Parse(s)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 12.6K bytes - Viewed (0) -
internal/grid/stream.go
// If any error is returned by the callback, the stream will be canceled. // If the context is canceled, the stream will be canceled. func (s *Stream) Results(next func(b []byte) error) (err error) { done := false defer func() { if s.cancel != nil { s.cancel(err) } if !done { // Drain channel. for range s.responses { } } }() doneCh := s.ctx.Done()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
) type ConnectionsFilter struct { Namespace string Direction string Raw bool } func (c *ConfigWriter) PrintConnectionsDump(filter ConnectionsFilter, outputFormat string) error { d := c.ztunnelDump workloads := maps.Values(d.WorkloadState) workloads = slices.SortFunc(workloads, func(a, b WorkloadState) int { if r := cmp.Compare(a.Info.Namespace, b.Info.Namespace); r != 0 { return r }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri May 31 21:45:11 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/handlers/proxy.go
protoRegex = regexp.MustCompile(`(?i)^(;|,| )+(?:proto=)(https|http)`) ) // GetSourceScheme retrieves the scheme from the X-Forwarded-Proto and RFC7239 // Forwarded headers (in that order). func GetSourceScheme(r *http.Request) string { var scheme string // Retrieve the scheme from X-Forwarded-Proto. if proto := r.Header.Get(xForwardedProto); proto != "" { scheme = strings.ToLower(proto)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 22 00:56:55 UTC 2023 - 5.1K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version_test.go
for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, c.version), func(t *testing.T) { got, err := extractKubernetesVersion(c.version) if c.errMsg != err && c.isValid { t.Fatalf("\nwanted: %v \nbut found: %v", c.errMsg, err) } if got != c.expected { t.Fatalf("wanted %v got %v", c.expected, got) } }) } } func TestIsK8VersionSupported(t *testing.T) { cases := []struct {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 30 21:50:50 UTC 2024 - 6.5K bytes - Viewed (0)