- Sort Score
- Result 10 results
- Languages All
Results 591 - 600 of 1,405 for rfunc (0.03 sec)
-
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/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) -
internal/disk/directio_darwin.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() _, err := unix.FcntlInt(fd, unix.F_NOCACHE, 0) return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 17 14:31:36 UTC 2023 - 1.4K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
const FileParseString = "Some files couldn't be parsed." func (f AnalyzerFoundIssuesError) Error() string { var sb strings.Builder sb.WriteString(fmt.Sprintf("Analyzers found issues when analyzing %s.\n", analyzeTargetAsString())) sb.WriteString(fmt.Sprintf("See %s for more information about causes and resolutions.", url.ConfigAnalysis)) return sb.String() } func (f FileParseError) Error() string { return FileParseString }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 31 06:53:50 UTC 2024 - 17.6K 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) -
clause/delete.go
package clause type Delete struct { Modifier string } func (d Delete) Name() string { return "DELETE" } func (d Delete) Build(builder Builder) { builder.WriteString("DELETE") if d.Modifier != "" { builder.WriteByte(' ') builder.WriteString(d.Modifier) } } func (d Delete) MergeClause(clause *Clause) { clause.Name = "" clause.Expression = d
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Mar 09 09:07:00 UTC 2020 - 359 bytes - Viewed (0) -
cmd/decommetric_string.go
// Code generated by "stringer -type=decomMetric -trimprefix=decomMetric erasure-server-pool-decom.go"; DO NOT EDIT. package cmd 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[decomMetricDecommissionBucket-0] _ = x[decomMetricDecommissionObject-1] _ = x[decomMetricDecommissionRemoveObject-2]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 10 19:46:45 UTC 2022 - 830 bytes - Viewed (0) -
cmd/bucket-lifecycle_test.go
import ( "bytes" "net/http" "testing" "time" "github.com/minio/minio/internal/bucket/lifecycle" xhttp "github.com/minio/minio/internal/http" ) // TestParseRestoreObjStatus tests parseRestoreObjStatus func TestParseRestoreObjStatus(t *testing.T) { testCases := []struct { restoreHdr string expectedStatus restoreObjStatus expectedErr error }{ { // valid: represents a restored object, 'pending' expiry.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 31 09:57:57 UTC 2022 - 7K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
pilotxds "istio.io/istio/pilot/pkg/xds" "istio.io/istio/pkg/log" ) var configDumpFile string func readConfigFile(filename string) ([]byte, error) { file := os.Stdin if filename != "-" { var err error file, err = os.Open(filename) if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
// Verify returns true if the passed workload matches the filter fields func (wf *PolicyFilter) Verify(pol *ZtunnelPolicy) bool { if wf.Namespace != "" { if !strings.EqualFold(pol.Namespace, wf.Namespace) { return false } } return true } // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintPolicySummary(filter PolicyFilter) error {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri May 31 21:45:11 UTC 2024 - 2.4K bytes - Viewed (0)