- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for workloadstate (0.33 sec)
-
istioctl/pkg/writer/ztunnel/configdump/connections.go
d := c.ztunnelDump workloads := maps.Values(d.WorkloadState) workloads = slices.SortFunc(workloads, func(a, b WorkloadState) int { if r := cmp.Compare(a.Info.Namespace, b.Info.Namespace); r != 0 { return r } return cmp.Compare(a.Info.Namespace, b.Info.Namespace) }) workloads = slices.FilterInPlace(workloads, func(state WorkloadState) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:11 UTC 2024 - 3.5K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
Workloads json.RawMessage `json:"workloads"` Policies json.RawMessage `json:"policies"` Certificates json.RawMessage `json:"certificates"` WorkloadState map[string]WorkloadState `json:"workloadstate"` } // Prime loads the config dump into the writer ready for printing func (c *ConfigWriter) Prime(b []byte) error { zDump := &ZtunnelDump{} rawDump := &rawDump{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 3.9K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/api.go
Services []*ZtunnelService `json:"services"` Policies []*ZtunnelPolicy `json:"policies"` Certificates []*CertsDump `json:"certificates"` WorkloadState map[string]WorkloadState `json:"workloadState"` } type CertsDump struct { Identity string `json:"identity"` State string `json:"state"` CertChain []*Cert `json:"certChain"` } type Cert struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
"HEALTHY": 0, "UNHEALTHY": 1, } ) func (x WorkloadStatus) Enum() *WorkloadStatus { p := new(WorkloadStatus) *p = x return p } func (x WorkloadStatus) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (WorkloadStatus) Descriptor() protoreflect.EnumDescriptor { return file_workloadapi_workload_proto_enumTypes[0].Descriptor()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K bytes - Viewed (0) -
pkg/workloadapi/workload.proto
// are returned out of band. // Authorization policies are only valid for workloads with `addresses` rather than `hostname`. repeated string authorization_policies = 16; WorkloadStatus status = 17; // The cluster ID that the workload instance belongs to string cluster_id = 18; // The Locality defines information about where a workload is geographically deployed
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
have.Insert(addr.Service.Name) } } return have }, want, retry.Timeout(time.Second*3)) } func (s *ambientTestServer) assertWorkloads(t *testing.T, lookup string, state workloadapi.WorkloadStatus, names ...string) { t.Helper() want := sets.New(names...) assert.EventuallyEqual(t, func() sets.String { workloads := s.lookup(lookup) have := sets.New[string]() for _, wl := range workloads {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)