- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 49 for responses (0.26 sec)
-
istioctl/pkg/writer/pilot/status.go
"istio.io/istio/pilot/pkg/model" xdsresource "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/log" ) // XdsStatusWriter enables printing of sync status using multiple xdsapi.DiscoveryResponse Istiod responses type XdsStatusWriter struct { Writer io.Writer Namespace string InternalDebugAllIstiod bool } type xdsWriterStatus struct { proxyID string
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
return nil, err } responses = append(responses, resp) return responses, nil } return responses, nil } func mergeShards(responses map[string]*discovery.DiscoveryResponse) (*discovery.DiscoveryResponse, error) { retval := discovery.DiscoveryResponse{} if len(responses) == 0 { return &retval, nil } for _, response := range responses {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
err := json.Unmarshal(resp, istiodDump) if err != nil { continue } c.istiod = istiodDump break } if c.istiod == nil { return nil, fmt.Errorf("unable to find config dump in Istiod responses") } envoyDump := &configdump.Wrapper{} err := json.Unmarshal(envoyResponse, envoyDump) if err != nil { return nil, err } c.envoy = envoyDump c.w = w c.context = 7
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
// limitations under the License. package configdump import ( "encoding/json" "fmt" "io" "text/tabwriter" "sigs.k8s.io/yaml" ) // ConfigWriter is a writer for processing responses from the Ztunnel Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer ztunnelDump *ZtunnelDump FullDump []byte } // Prime loads the config dump into the writer ready for printing
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump.go
"sigs.k8s.io/yaml" "istio.io/istio/istioctl/pkg/util/configdump" sdscompare "istio.io/istio/istioctl/pkg/writer/compare/sds" "istio.io/istio/pkg/util/protomarshal" ) // ConfigWriter is a writer for processing responses from the Envoy Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer configDump *configdump.Wrapper } // includeConfigType is a flag to indicate whether to include the config type in the output
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 29 20:46:41 GMT 2024 - 7.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/clusters/clusters.go
type EndpointFilter struct { Address string 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 {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 5.8K bytes - Viewed (0) -
istioctl/pkg/util/common.go
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.6K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration func DialOptions(opts clioptions.CentralControlPlaneOptions,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
common-protos/k8s.io/api/authentication/v1/generated.proto
// ExpirationSeconds is the requested duration of validity of the request. The // token issuer may return a token with a different validity duration so a // client needs to check the 'expiration' field in a response. // +optional optional int64 expirationSeconds = 4; // BoundObjectRef is a reference to an object that the token will be bound to. // The token will only be valid for as long as the bound object exists.
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 6.7K bytes - Viewed (0) -
common-protos/k8s.io/api/core/v1/generated.proto
// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes // +optional optional Probe startupProbe = 22; // Actions that the management system should take in response to container lifecycle events. // Cannot be updated. // +optional optional Lifecycle lifecycle = 12; // Optional: Path at which the file to which the container's termination message
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 255.8K bytes - Viewed (0)