Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for Wrapper (0.23 sec)

  1. istioctl/pkg/util/configdump/wrapper.go

    		return msg.ProtoReflect().Type(), nil
    	}
    	return typ, nil
    }
    
    // Wrapper is a wrapper around the Envoy ConfigDump
    // It has extra helper functions for handling any/struct/marshal protobuf pain
    type Wrapper struct {
    	*admin.ConfigDump
    }
    
    // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
    func (w *Wrapper) UnmarshalJSON(b []byte) error {
    	cd := &admin.ConfigDump{}
    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)
  2. istioctl/pkg/util/clusters/wrapper.go

    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    // Wrapper is a wrapper around the Envoy Clusters
    // It has extra helper functions for handling any/struct/marshal protobuf pain
    type Wrapper struct {
    	*admin.Clusters
    }
    
    // MarshalJSON is a custom marshaller to handle protobuf pain
    func (w *Wrapper) MarshalJSON() ([]byte, error) {
    	return protomarshal.Marshal(w)
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 1.2K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/compare/comparator.go

    type Comparator struct {
    	envoy, istiod *configdump.Wrapper
    	w             io.Writer
    	context       int
    	location      string
    }
    
    // NewComparator is a comparator constructor
    func NewComparator(w io.Writer, istiodResponses map[string][]byte, envoyResponse []byte) (*Comparator, error) {
    	c := &Comparator{}
    	for _, resp := range istiodResponses {
    		istiodDump := &configdump.Wrapper{}
    		err := json.Unmarshal(resp, istiodDump)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 3.7K bytes
    - Viewed (1)
  4. istioctl/pkg/util/configdump/util.go

    	ecds      configTypeURL = "type.googleapis.com/envoy.admin.v3.EcdsConfigDump"
    )
    
    // getSection takes a TypeURL and returns the types.Any from the config dump corresponding to that URL
    func (w *Wrapper) getSection(sectionTypeURL configTypeURL) (*anypb.Any, error) {
    	var dumpAny *anypb.Any
    	for _, conf := range w.Configs {
    		if conf.TypeUrl == string(sectionTypeURL) {
    			dumpAny = conf
    		}
    	}
    	if dumpAny == nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Dec 24 08:16:26 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  5. istioctl/pkg/util/configdump/listener.go

    	listener "github.com/envoyproxy/go-control-plane/envoy/config/listener/v3"
    
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    )
    
    // GetDynamicListenerDump retrieves a listener dump with just dynamic active listeners in it
    func (w *Wrapper) GetDynamicListenerDump(stripVersions bool) (*admin.ListenersConfigDump, error) {
    	listenerDump, err := w.GetListenerConfigDump()
    	if err != nil {
    		return nil, err
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 2.5K bytes
    - Viewed (1)
  6. istioctl/pkg/writer/envoy/clusters/clusters.go

    	Port    uint32
    	Cluster string
    	Status  string
    }
    
    // ConfigWriter is a writer for processing responses from the Envoy Admin config_dump endpoint
    type ConfigWriter struct {
    	Stdout   io.Writer
    	clusters *clusters.Wrapper
    }
    
    // EndpointCluster is used to store the endpoint and cluster
    type EndpointCluster struct {
    	address            string
    	port               int
    	cluster            string
    	status             core.HealthStatus
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 5.8K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/compare/sds/util.go

    	}
    	result.Valid = false
    	return result, nil
    }
    
    // GetEnvoySecrets parses the secrets section of the config dump into []SecretItem
    func GetEnvoySecrets(
    	wrapper *configdump.Wrapper,
    ) ([]SecretItem, error) {
    	secretConfigDump, err := wrapper.GetSecretConfigDump()
    	if err != nil {
    		return nil, err
    	}
    
    	proxySecretItems := make([]SecretItem, 0)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Jun 06 15:14:48 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  8. istioctl/pkg/authz/analyzer_test.go

    	"istio.io/istio/istioctl/pkg/util/configdump"
    )
    
    func TestNewAnalyzer(t *testing.T) {
    	tests := []struct {
    		name    string
    		input   *configdump.Wrapper
    		wantErr error
    	}{
    		{
    			name: "Test1",
    			input: &configdump.Wrapper{
    				ConfigDump: &envoy_admin.ConfigDump{
    					Configs: []*anypb.Any{
    						{
    							TypeUrl: "type.googleapis.com/envoy.admin.v3.ListenersConfigDump",
    						},
    					},
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  9. istioctl/pkg/util/configdump/route.go

    	"istio.io/istio/pilot/pkg/util/protoconv"
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    )
    
    // GetLastUpdatedDynamicRouteTime retrieves the LastUpdated timestamp of the
    // most recently updated DynamicRouteConfig
    func (w *Wrapper) GetLastUpdatedDynamicRouteTime() (*time.Time, error) {
    	routeDump, err := w.GetRouteConfigDump()
    	if err != nil {
    		return nil, err
    	}
    	drc := routeDump.GetDynamicRouteConfigs()
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 3.2K bytes
    - Viewed (0)
  10. istioctl/pkg/util/configdump/bootstrap.go

    package configdump
    
    import (
    	admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3"
    )
    
    // GetBootstrapConfigDump retrieves the bootstrap config dump from the ConfigDump
    func (w *Wrapper) GetBootstrapConfigDump() (*admin.BootstrapConfigDump, error) {
    	bootstrapDumpAny, err := w.getSection(bootstrap)
    	if err != nil {
    		return nil, err
    	}
    	bootstrapDump := &admin.BootstrapConfigDump{}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 1.1K bytes
    - Viewed (0)
Back to top