- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 105 for type (0.36 sec)
-
istioctl/pkg/writer/compare/sds/writer.go
// SDSWriter takes lists of SecretItem or SecretItemDiff and prints them through supplied output writer type SDSWriter interface { PrintSecretItems([]SecretItem) error PrintDiffs([]SecretItemDiff) error } type Format int const ( JSON Format = iota TABULAR ) // includeConfigType is a flag to indicate whether to include the config type in the output var includeConfigType bool func SetPrintConfigTypeInSummary(p bool) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 21 14:17:23 GMT 2023 - 4.1K bytes - Viewed (0) -
istioctl/pkg/util/configdump/wrapper.go
msg := exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}} return msg.ProtoReflect().Type(), nil } return typ, nil } // Wrapper is a wrapper around the Envoy ConfigDump // It has extra helper functions for handling any/struct/marshal protobuf pain type Wrapper struct { *admin.ConfigDump } // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 1.8K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter.go
return fmt.Sprintf("%s%v%s [%v]%s %s", colorPrefix(m, colorize), m.Type.Level(), colorSuffix(colorize), m.Type.Code(), m.Origin(), fmt.Sprintf(m.Type.Template(), m.Parameters...), ) } func colorPrefix(m diag.Message, colorize bool) string { if !colorize { return "" } prefix, ok := colorPrefixes[m.Type.Level()] if !ok { return "" } return prefix }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
} mt, err := protoregistry.GlobalTypes.FindMessageByName(protoreflect.FullName(mname)) if err != nil { // istioctl should keep going if it encounters new Envoy versions; ignore unknown types return &exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}}, nil } return legacyproto.MessageV1(mt.New().Interface()), nil
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) -
istioctl/pkg/writer/envoy/clusters/clusters.go
type EndpointFilter struct { Address string Port uint32 Cluster string Status string } // ConfigWriter is a writer for processing responses from the Envoy Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer clusters *clusters.Wrapper } // EndpointCluster is used to store the endpoint and cluster type EndpointCluster struct {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 5.8K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
) var ErrPodNotFound = errors.New("netns not provided, but is needed as pod is not in cache") type PodNetnsCache interface { ReadCurrentPodSnapshot() map[string]WorkloadInfo } // Hold a cache of node local pods with their netns // if we don't know the netns, the pod will still be here with a nil netns. type podNetnsCache struct { openNetns func(nspath string) (NetnsCloser, error) currentPodCache map[string]WorkloadInfo
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig_test.go
package admin import ( "net/http" "net/http/httptest" "net/url" "os" "reflect" "testing" ) func Test_newScopeLevelPair(t *testing.T) { validationPattern := `^\w+:(debug|error|warn|info|debug)` type args struct { slp string validationPattern string } tests := []struct { name string args args want *ScopeLevelPair wantErr bool }{ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 6.2K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
} func DebugCommand(ctx cli.Context) *cobra.Command { var opts clioptions.ControlPlaneOptions var centralOpts clioptions.CentralControlPlaneOptions debugCommand := &cobra.Command{ Use: "internal-debug [<type>/]<name>[.<namespace>]", Short: "Retrieves the debug information of istio", Long: ` Retrieves the debug information from Istiod or Pods in the mesh using the service account from the pod if --cert-dir is empty.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
"k8s.io/client-go/rest" pconstants "istio.io/istio/cni/pkg/constants" "istio.io/istio/cni/pkg/ipset" "istio.io/istio/cni/pkg/iptables" "istio.io/istio/cni/pkg/util" "istio.io/istio/pkg/kube" ) type MeshDataplane interface { // called first, (even before Start()). ConstructInitialSnapshot(ambientPods []*corev1.Pod) error Start(ctx context.Context)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint_test.go
conditions := make([]metav1.Condition, 0) if programmed { conditions = append(conditions, metav1.Condition{ Type: string(gateway.GatewayConditionProgrammed), Status: kstatus.StatusTrue, }) } else { conditions = append(conditions, metav1.Condition{ Type: string(gateway.GatewayConditionProgrammed), Status: kstatus.StatusFalse, }) } className := "other" if isWaypoint {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 15:53:09 GMT 2024 - 4.4K bytes - Viewed (0)