- Sort Score
- Result 10 results
- Languages All
Results 591 - 600 of 1,387 for funcs (0.48 sec)
-
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) -
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) -
internal/logger/target/types/targettype_string.go
package types import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[TargetConsole-1] _ = x[TargetHTTP-2] _ = x[TargetKafka-3] } const _TargetType_name = "ConsoleHTTPKafka" var _TargetType_index = [...]uint8{0, 7, 11, 16} func (i TargetType) String() string { i -= 1
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Nov 10 18:20:21 UTC 2022 - 703 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) -
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) -
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) -
cmd/endpoint_contrib_test.go
*/ package cmd import ( "testing" "github.com/minio/minio-go/v7/pkg/set" ) func TestUpdateDomainIPs(t *testing.T) { tempGlobalMinioPort := globalMinioPort defer func() { globalMinioPort = tempGlobalMinioPort }() globalMinioPort = "9000" tempGlobalDomainIPs := globalDomainIPs defer func() { globalDomainIPs = tempGlobalDomainIPs }() ipv4TestCases := []struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 30 15:50:39 UTC 2021 - 2.2K bytes - Viewed (0)