- Sort Score
- Result 10 results
- Languages All
Results 581 - 590 of 1,425 for Func (0.04 sec)
-
istioctl/pkg/config/config_test.go
xds-port 15012 default `, WantException: false, }, } for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.Args, " ")), func(t *testing.T) { testutil.VerifyOutput(t, Cmd(), c) }) } } func init() { viper.SetDefault("istioNamespace", constants.IstioSystemNamespace) viper.SetDefault("xds-port", 15012)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.8K bytes - Viewed (0) -
istioctl/pkg/util/formatting/msg_threshold.go
diag.Level } // String is a function declared in the pflag.Value interface func (m *MessageThreshold) String() string { return m.Level.String() } // Type is a function declared in the pflag.Value interface func (m *MessageThreshold) Type() string { return "Level" } // Set is a function declared in the pflag.Value interface func (m *MessageThreshold) Set(s string) error { levelMap := diag.GetUppercaseStringToLevelMap()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Nov 17 12:28:05 UTC 2021 - 1.4K 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) -
cmd/object-lambda-handlers.go
// if the text is unknown. func StatusCode(text string) int { if code, ok := statusTextToCode[text]; ok { return code } return -1 } func fwdHeadersToS3(h http.Header, w http.ResponseWriter) { const trim = "x-amz-fwd-header-" for k, v := range h { if stringsHasPrefixFold(k, trim) { w.Header()[k[len(trim):]] = v } } } func fwdStatusToAPIError(resp *http.Response) *APIError {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 10.3K bytes - Viewed (0) -
src/cmd/asm/internal/arch/arch.go
RegisterPrefix map[string]bool // RegisterNumber converts R(10) into arm.REG_R10. RegisterNumber func(string, int16) (int16, bool) // Instruction is a jump. IsJump func(word string) bool } // nilRegisterNumber is the register number function for architectures // that do not accept the R(N) notation. It always returns failure. func nilRegisterNumber(name string, n int16) (int16, bool) { return 0, false }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Oct 24 12:32:56 UTC 2024 - 21.5K 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) -
cmd/config-current.go
MultipleTargets: subSysHelp.MultipleTargets, KeysHelp: help, }, nil } func newServerConfig() config.Config { return config.New() } // newSrvConfig - initialize a new server config, saves env parameters if // found, otherwise use default parameters func newSrvConfig(objAPI ObjectLayer) error { // Initialize server config. srvCfg := newServerConfig()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 30.1K bytes - Viewed (0) -
cmd/metrics-v2.go
} // RegisterRead register the metrics populator function to be used // to populate new values upon cache invalidation. func (g *MetricsGroupV2) RegisterRead(read func(context.Context) []MetricV2) { g.metricsCache = cachevalue.NewFromFunc(g.cacheInterval, cachevalue.Opts{ReturnLastGood: true}, func(ctx context.Context) ([]MetricV2, error) { if g.metricsGroupOpts.dependGlobalObjectAPI { objLayer := newObjectLayerFn()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K 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)