- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for Balint (0.35 sec)
-
internal/s3select/csv/reader.go
for len(r.current) <= r.recordsRead { if r.err != nil { return nil, r.err } // Move to next block item, ok := <-r.queue if !ok { r.err = io.EOF return nil, r.err } //nolint:staticcheck // SA6002 Using pointer would allocate more since we would have to copy slice header before taking a pointer. r.csvDstPool.Put(r.current) r.current = <-item.dst r.err = item.err r.recordsRead = 0 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
makeCGroups := func(groupPaths []string) []Cgroup { var out []Cgroup for _, groupPath := range groupPaths { out = append(out, Cgroup{ GroupPath: groupPath, }) } return out } //nolint: lll for _, tt := range []struct { name string cgroupPaths []string expectPodUID types.UID expectContainerID string expectMsg string }{ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
"fmt" "io" "strings" admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" legacyproto "github.com/golang/protobuf/proto" // nolint: staticcheck exprpb "google.golang.org/genproto/googleapis/api/expr/v1alpha1" "google.golang.org/protobuf/reflect/protoreflect" "google.golang.org/protobuf/reflect/protoregistry"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1) -
logger/sql.go
v, _ = valuer.Value() convertParams(v, idx) } else if rv.Kind() == reflect.Ptr && !rv.IsZero() { convertParams(reflect.Indirect(rv).Interface(), idx) } else if isNumeric(rv.Kind()) { if rv.CanInt() || rv.CanUint() { vars[idx] = fmt.Sprintf("%d", rv.Interface()) } else { vars[idx] = fmt.Sprintf("%.6f", rv.Interface()) } } else { for _, t := range convertibleTypes {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 21 08:00:02 GMT 2024 - 5K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
func getServiceAccountsName(kubeClient kube.CLIClient, toComplete, ns string) ([]string, error) { ctx := context.Background() saList, err := kubeClient.Kube().CoreV1().ServiceAccounts(ns).List(ctx, metav1.ListOptions{}) if err != nil { return nil, err } var saNameList []string for _, sa := range saList.Items { if toComplete == "" || strings.HasPrefix(sa.Name, toComplete) { saNameList = append(saNameList, sa.Name) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
return nil, fmt.Errorf("failed to create RPC credentials for \"%s.%s\": %w", serviceAccount, ns, err) } if isMCP { return mcpDialOptions(ctx, opts.GCPProject, k8sCreds) } return []grpc.DialOption{ // nolint: gosec // Only runs over istioctl experimental // TODO: https://github.com/istio/istio/issues/41937 grpc.WithTransportCredentials(credentials.NewTLS( &tls.Config{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/admin-server-info.go
props.PoolNumbers = append(props.PoolNumbers, poolNumber) } sort.Ints(props.PoolNumbers) props.PoolNumber = func() int { if len(props.PoolNumbers) == 1 { return props.PoolNumbers[0] } return math.MaxInt // this indicates that its unset. }() sensitive := map[string]struct{}{ config.EnvAccessKey: {}, config.EnvSecretKey: {}, config.EnvRootUser: {},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.8K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
return configs } // FIXME: currently removing the deprecated code below may result in functions not working // if there is a mismatch of versions between istiod and istioctl // nolint: staticcheck for _, config := range clientConfig.GetXdsConfig() { var typeURL string switch config.PerXdsConfig.(type) { case *xdsstatus.PerXdsConfig_ListenerConfig: typeURL = xdsresource.ListenerType
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate.go
return &cobra.Command{ Use: "generate", Short: "Generates an Istio install manifest", Long: "The generate subcommand generates an Istio install manifest and outputs to the console by default.", // nolint: lll Example: ` # Generate a default Istio installation istioctl manifest generate # Enable Tracing istioctl manifest generate --set meshConfig.enableTracing=true # Generate the demo profile
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics_test.go
&prometheus_model.Sample{Value: 0.04}, }, "sum(rate(istio_requests_total{destination_workload=~\"details.*\", destination_workload_namespace=~\".*\",reporter=\"destination\",response_code=~\"[45][0-9]{2}\"}[1m0s]))": prometheus_model.Vector{}, // nolint: lll
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 25 02:07:44 GMT 2023 - 7.9K bytes - Viewed (0)