- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 297 for primed (0.12 sec)
-
istioctl/pkg/writer/envoy/configdump/configdump.go
var includeConfigType bool func SetPrintConfigTypeInSummary(p bool) { includeConfigType = p } // Prime loads the config dump into the writer ready for printing func (c *ConfigWriter) Prime(b []byte) error { w := &configdump.Wrapper{} err := w.UnmarshalJSON(b) if err != nil { return fmt.Errorf("error unmarshalling config dump response from Envoy: %v", err) }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Feb 29 20:46:41 UTC 2024 - 7.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/clusters/clusters.go
address string port int cluster string status core.HealthStatus failedOutlierCheck bool } // Prime loads the clusters output into the writer ready for printing func (c *ConfigWriter) Prime(b []byte) error { cd := clusters.Wrapper{} err := json.Unmarshal(b, &cd) if err != nil { return fmt.Errorf("error unmarshalling config dump response from Envoy: %v", err) }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 5.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump_test.go
}, { name: "errors if config dump is not primed", wantErr: true, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { gotOut := &bytes.Buffer{} cw := &ConfigWriter{Stdout: gotOut} cd, _ := os.ReadFile("testdata/configdump.json") if tt.callPrime { cw.Prime(cd) } err := cw.PrintBootstrapDump("json") if tt.wantOutputFile != "" {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jan 03 23:08:06 UTC 2024 - 3.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/ecds.go
) const typeURLPrefix = "type.googleapis.com/" func (c *ConfigWriter) PrintEcds(outputFormat string) error { if c.configDump == nil { return fmt.Errorf("config writer has not been primed") } dump, err := c.configDump.GetEcdsConfigDump() if err != nil { return err } out, err := protomarshal.MarshalIndentWithGlobalTypesResolver(dump, " ") if err != nil { return err }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Jan 14 02:41:27 UTC 2023 - 2.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
} return result } func (c *ConfigWriter) PrintEndpoints(filter EndpointFilter, outputFormat string) error { if c.configDump == nil { return fmt.Errorf("config writer has not been primed") } dump, err := c.retrieveSortedEndpointsSlice(filter) if err != nil { return err } marshaller := make(proto.MessageSlice, 0, len(dump)) for _, eds := range dump {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Jul 22 09:57:29 UTC 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
) // PrintSecretDump prints just the secret config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintSecretDump(outputFormat string) error { if c.ztunnelDump == nil { return fmt.Errorf("config writer has not been primed") } secretDump := c.ztunnelDump.Certificates out, err := json.MarshalIndent(secretDump, "", " ") if err != nil { return fmt.Errorf("failed to marshal secrets dump: %v", err) } if outputFormat == "yaml" {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Apr 25 16:38:16 UTC 2024 - 3.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump_test.go
}{ { name: "returns expected secret summary onto Stdout", callPrime: true, wantOutputSecret: "testdata/secretsummary.txt", }, { name: "errors if config dump is not primed", wantErr: true, }, { name: "returns expected workload summary onto Stdout", callPrime: true, wantOutputWorkload: "testdata/workloadsummary.txt", }, {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route.go
return w, routes, nil } func (c *ConfigWriter) retrieveSortedRouteSlice() ([]*route.RouteConfiguration, error) { if c.configDump == nil { return nil, fmt.Errorf("config writer has not been primed") } routeDump, err := c.configDump.GetRouteConfigDump() if err != nil { return nil, err } routes := make([]*route.RouteConfiguration, 0) for _, r := range routeDump.DynamicRouteConfigs {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 08 20:44:50 UTC 2024 - 7.2K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/cluster.go
return w, clusters, nil } func (c *ConfigWriter) retrieveSortedClusterSlice() ([]*cluster.Cluster, error) { if c.configDump == nil { return nil, fmt.Errorf("config writer has not been primed") } clusterDump, err := c.configDump.GetClusterConfigDump() if err != nil { return nil, err } clusters := make([]*cluster.Cluster, 0) for _, c := range clusterDump.DynamicActiveClusters {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu May 11 05:38:17 UTC 2023 - 5.9K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
return w, listeners, nil } func (c *ConfigWriter) retrieveSortedListenerSlice() ([]*listener.Listener, error) { if c.configDump == nil { return nil, fmt.Errorf("config writer has not been primed") } listenerDump, err := c.configDump.GetListenerConfigDump() if err != nil { return nil, fmt.Errorf("listener dump: %v", err) } listeners := make([]*listener.Listener, 0)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 18.1K bytes - Viewed (0)