Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for sunt (0.17 sec)

  1. istioctl/pkg/proxystatus/proxystatus.go

    	var multiXdsOpts multixds.Options
    
    	statusCmd := &cobra.Command{
    		Use:   "proxy-status [<type>/]<name>[.<namespace>]",
    		Short: "Retrieves the synchronization status of each Envoy in the mesh",
    		Long: `
    Retrieves last sent and last acknowledged xDS sync from Istiod to each Envoy in the mesh
    `,
    		Example: `  # Retrieve sync status for all Envoys in a mesh
      istioctl proxy-status
    
      # Retrieve sync status for Envoys in a specific namespace
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    			}
    		}()
    	}
    }
    
    // ZDS protocol is very simple, for every message sent, and ack is sent.
    // the ack only has temporal correlation (i.e. it is the first and only ack msg after the message was sent)
    // All this to say, that we want to make sure that message to ztunnel are sent from a single goroutine
    // so we don't mix messages and acks.
    // nolint: unparam
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/pilot/status.go

    }
    
    func formatStatus(s *xdsstatus.ClientConfig_GenericXdsConfig) string {
    	switch s.GetConfigStatus() {
    	case xdsstatus.ConfigStatus_UNKNOWN:
    		return ignoredStatus
    	case xdsstatus.ConfigStatus_NOT_SENT:
    		return "NOT SENT"
    	default:
    		return s.GetConfigStatus().String()
    	}
    }
    
    func getSyncStatus(clientConfig *xdsstatus.ClientConfig) (cds, lds, eds, rds, ecds string) {
    	configs := handleAndGetXdsConfigs(clientConfig)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 04:16:55 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/ztunnelserver_test.go

    	// send ack so the server doesn't wait for us.
    	sendAck(ztunClient)
    
    	// second message should be the snap sent message
    	m, fds = readRequest(t, ztunClient)
    	assert.Equal(t, len(fds), 0)
    
    	sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent
    	if sent == nil {
    		panic("expected snapshot sent")
    	}
    	sendAck(ztunClient)
    	ztunClient.Close()
    	// this will retry for a bit, so shouldn't flake
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 8.6K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/pilot/status_test.go

    						clusterID:      "cluster3",
    						version:        "1.20",
    						cdsSyncStatus:  status.ConfigStatus_NOT_SENT,
    						ldsSyncStatus:  status.ConfigStatus_ERROR,
    						rdsSyncStatus:  status.ConfigStatus_NOT_SENT,
    						edsSyncStatus:  status.ConfigStatus_STALE,
    						ecdsSyncStatus: status.ConfigStatus_NOT_SENT,
    					},
    				}),
    				"istiod4": xdsResponseInput("istiod4", []clientConfigInput{
    					{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 6.5K bytes
    - Viewed (0)
Back to top