- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for IstioStatus (0.14 sec)
-
pkg/config/schema/collections/collections.agent.gen.go
VersionAliases: []string{ "v1", }, Proto: "istio.security.v1beta1.AuthorizationPolicy", StatusProto: "istio.meta.v1alpha1.IstioStatus", ReflectType: reflect.TypeOf(&istioioapisecurityv1beta1.AuthorizationPolicy{}).Elem(), StatusType: reflect.TypeOf(&istioioapimetav1alpha1.IstioStatus{}).Elem(), ProtoPackage: "istio.io/api/security/v1beta1", StatusPackage: "istio.io/api/meta/v1alpha1", ClusterScoped: false, Synthetic: false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 12.9K bytes - Viewed (0) -
pkg/config/schema/metadata.yaml
statusProtoPackage: "istio.io/api/meta/v1alpha1" - kind: "WorkloadGroup" plural: "workloadgroups" group: "networking.istio.io" version: "v1alpha3" versionAliases: - "v1beta1" - "v1" proto: "istio.networking.v1alpha3.WorkloadGroup" protoPackage: "istio.io/api/networking/v1alpha3" statusProto: "istio.meta.v1alpha1.IstioStatus"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 17:37:32 UTC 2024 - 13.2K bytes - Viewed (0) -
pilot/pkg/model/status/helper.go
return nil } func UpdateConfigCondition(cfg config.Config, condition *v1alpha1.IstioCondition) config.Config { cfg = cfg.DeepCopy() var status *v1alpha1.IstioStatus if cfg.Status == nil { cfg.Status = &v1alpha1.IstioStatus{} } status = cfg.Status.(*v1alpha1.IstioStatus) status.Conditions = updateCondition(status.Conditions, condition) return cfg }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 21 15:06:10 UTC 2023 - 2.9K bytes - Viewed (0) -
pilot/pkg/status/distribution/state_test.go
} }) } } func Test_getTypedStatus(t *testing.T) { x := v1alpha1.IstioStatus{} b, _ := json.Marshal(statusStillPropagating) _ = json.Unmarshal(b, &x) type args struct { in any } tests := []struct { name string args args wantOut *v1alpha1.IstioStatus wantErr bool }{ { name: "Nondestructive cast",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 22 22:47:47 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/config/schema/collections/collections.gen.go
VersionAliases: []string{ "v1", }, Proto: "istio.security.v1beta1.AuthorizationPolicy", StatusProto: "istio.meta.v1alpha1.IstioStatus", ReflectType: reflect.TypeOf(&istioioapisecurityv1beta1.AuthorizationPolicy{}).Elem(), StatusType: reflect.TypeOf(&istioioapimetav1alpha1.IstioStatus{}).Elem(), ProtoPackage: "istio.io/api/security/v1beta1", StatusPackage: "istio.io/api/meta/v1alpha1", ClusterScoped: false, Synthetic: false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 31.4K bytes - Viewed (0) -
pilot/pkg/status/manager.go
} return result } func (m *Manager) CreateIstioStatusController(fn func(status *v1alpha1.IstioStatus, context any) *v1alpha1.IstioStatus) *Controller { wrapper := func(status any, context any) GenerationProvider { var input *v1alpha1.IstioStatus if status != nil { converted := status.(*IstioGenerationProvider) input = converted.IstioStatus } result := fn(input, context) return &IstioGenerationProvider{result} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 4.2K bytes - Viewed (0) -
pilot/pkg/status/resource.go
} } func GetTypedStatus(in any) (out *v1alpha1.IstioStatus, err error) { if ret, ok := in.(*v1alpha1.IstioStatus); ok { return ret, nil } return nil, fmt.Errorf("cannot cast %T: %v to IstioStatus", in, in) } func GetOGProvider(in any) (out GenerationProvider, err error) { if ret, ok := in.(*v1alpha1.IstioStatus); ok && ret != nil { return &IstioGenerationProvider{ret}, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 30 16:13:59 UTC 2023 - 3.2K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
UpdateInterval: 200 * time.Millisecond, StaleInterval: time.Minute, clock: clock.RealClock{}, configStore: cs, workers: m.CreateIstioStatusController(func(status *v1alpha1.IstioStatus, context any) *v1alpha1.IstioStatus { if status == nil { return nil } distributionState := context.(Progress) if needsReconcile, desiredStatus := ReconcileStatuses(status, distributionState); needsReconcile {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
pilot/pkg/status/resourcelock_test.go
Namespace: "r1", Name: "r1", Generation: "12", } var runCount int32 x := make(chan struct{}) y := make(chan struct{}) mgr := NewManager(nil) fakefunc := func(status *v1alpha1.IstioStatus, context any) *v1alpha1.IstioStatus { x <- struct{}{} atomic.AddInt32(&runCount, 1) y <- struct{}{} return nil } c1 := mgr.CreateIstioStatusController(fakefunc) c2 := mgr.CreateIstioStatusController(fakefunc)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 2.1K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/health/util.go
// HasHealthCondition returns true if a given WorkloadEntry has ConditionHealthy // condition. func HasHealthCondition(wle *config.Config) bool { if wle == nil { return false } s, ok := wle.Status.(*v1alpha1.IstioStatus) if !ok { return false } return status.GetCondition(s.Conditions, status.ConditionHealthy) != nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 11 07:04:17 UTC 2023 - 1.7K bytes - Viewed (0)