Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for workloadstate (0.33 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top