- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 211 for error (0.12 sec)
-
istioctl/pkg/util/configdump/wrapper.go
*protoregistry.Types } var nonStrictResolver = &resolver{protoregistry.GlobalTypes} func (r *resolver) FindMessageByURL(url string) (protoreflect.MessageType, error) { typ, err := r.Types.FindMessageByURL(url) if err != nil { // Here we ignore the error since we want istioctl to ignore unknown types due to the Envoy version change msg := exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}}
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/writer/compare/listener.go
) // ListenerDiff prints a diff between Istiod and Envoy listeners to the passed writer func (c *Comparator) ListenerDiff() error { envoyBytes, istiodBytes := &bytes.Buffer{}, &bytes.Buffer{} envoyListenerDump, err := c.envoy.GetDynamicListenerDump(true) if err != nil { envoyBytes.WriteString(err.Error()) } else { envoy, err := protomarshal.ToJSONWithAnyResolver(envoyListenerDump, " ", &envoyResolver) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 20:29:08 GMT 2024 - 2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
func (s *InformerHandlers) reconcile(input any) error { event := input.(controllers.Event) switch event.Latest().(type) { case *corev1.Namespace: return s.reconcileNamespace(input) case *corev1.Pod: return s.reconcilePod(input) default: return fmt.Errorf("unexpected event type: %+v", input) } } func (s *InformerHandlers) reconcileNamespace(input any) error { event := input.(controllers.Event)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_unspecified.go
package plugin import "errors" // ErrNotImplemented is returned when a requested feature is not implemented. var ErrNotImplemented = errors.New("not implemented") // Program defines a method which programs iptables based on the parameters // provided in Redirect. func (ipt *iptables) Program(podName, netns string, rdrct *Redirect) error { return ErrNotImplemented
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.1K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_linux.go
if err := cfg.FillConfigFromEnvironment(); err != nil { return err } netNs, err := getNs(netns) if err != nil { err = fmt.Errorf("failed to open netns %q: %s", netns, err) return err } defer netNs.Close() return netNs.Do(func(_ ns.NetNS) error { log.Infof("============= Start iptables configuration for %v =============", podName)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 17:36:41 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump_test.go
} } else if len(cw.configDump.Configs) != tt.wantConfigs { t.Errorf("wanted %v configs loaded in got %v", tt.wantConfigs, len(cw.configDump.Configs)) } if tt.wantErr { assert.Error(t, err) } else { assert.NoError(t, err) } }) } } func TestConfigWriter_PrintBootstrapDump(t *testing.T) { tests := []struct { name string wantOutputFile string callPrime bool
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 03 23:08:06 GMT 2024 - 3.5K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
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" {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0) -
istioctl/pkg/kubeinject/google.go
} func mcpTransport(ctx context.Context, tr http.RoundTripper) (http.RoundTripper, error) { creds, err := google.FindDefaultCredentials(ctx, "https://www.googleapis.com/auth/cloud-platform") if err != nil { return nil, fmt.Errorf("finding default GCP credentials: %w", err) } return &oauth2.Transport{ Base: tr, Source: creds.TokenSource, }, nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.2K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1alpha1/generated.proto
// +optional optional VolumeError detachError = 4; } // VolumeError captures an error encountered during a volume operation. message VolumeError { // time represents the time the error was encountered. // +optional optional k8s.io.apimachinery.pkg.apis.meta.v1.Time time = 1; // message represents the error encountered during Attach or Detach operation.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 9.4K bytes - Viewed (0) -
common-protos/k8s.io/api/rbac/v1/generated.proto
// +optional repeated Subject subjects = 2; // RoleRef can only reference a ClusterRole in the global namespace. // If the RoleRef cannot be resolved, the Authorizer must return an error. optional RoleRef roleRef = 3; } // ClusterRoleBindingList is a collection of ClusterRoleBindings message ClusterRoleBindingList { // Standard object's metadata. // +optional
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 7.6K bytes - Viewed (0)