Documentation
¶
Index ¶
- Variables
- func AllRequestAndProcessXds(dr *discovery.DiscoveryRequest, ...) (map[string]*discovery.DiscoveryResponse, error)
- func CpInfo(xdsResponse *discovery.DiscoveryResponse) pilotxds.IstioControlPlaneInstance
- func FirstRequestAndProcessXds(dr *discovery.DiscoveryRequest, ...) (map[string]*discovery.DiscoveryResponse, error)
- func MultiRequestAndProcessXds(all bool, dr *discovery.DiscoveryRequest, ...) (map[string]*discovery.DiscoveryResponse, error)
- func RequestAndProcessXds(dr *discovery.DiscoveryRequest, ...) (*discovery.DiscoveryResponse, error)
- type ControlPlaneNotFoundError
- type Options
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultOptions = Options{ MessageWriter: os.Stdout, XdsViaAgents: false, XdsViaAgentsLimit: 0, }
View Source
var GetXdsResponse = xds.GetXdsResponse
Functions ¶
func AllRequestAndProcessXds ¶
func AllRequestAndProcessXds(dr *discovery.DiscoveryRequest, centralOpts clioptions.CentralControlPlaneOptions, istioNamespace string, ns string, serviceAccount string, kubeClient kube.CLIClient, options Options, ) (map[string]*discovery.DiscoveryResponse, error)
AllRequestAndProcessXds returns all XDS responses from 1 central or 1..N K8s cluster-based XDS servers nolint: lll
func CpInfo ¶
func CpInfo(xdsResponse *discovery.DiscoveryResponse) pilotxds.IstioControlPlaneInstance
CpInfo returns the Istio control plane info from JSON-encoded XDS ControlPlane Identifier
func FirstRequestAndProcessXds ¶
func FirstRequestAndProcessXds(dr *discovery.DiscoveryRequest, centralOpts clioptions.CentralControlPlaneOptions, istioNamespace string, ns string, serviceAccount string, kubeClient kube.CLIClient, options Options, ) (map[string]*discovery.DiscoveryResponse, error)
FirstRequestAndProcessXds returns all XDS responses from 1 central or 1..N K8s cluster-based XDS servers, stopping after the first response that returns any resources. nolint: lll
func MultiRequestAndProcessXds ¶
func MultiRequestAndProcessXds(all bool, dr *discovery.DiscoveryRequest, centralOpts clioptions.CentralControlPlaneOptions, istioNamespace string, ns string, serviceAccount string, kubeClient kube.CLIClient, options Options, ) (map[string]*discovery.DiscoveryResponse, error)
nolint: lll
func RequestAndProcessXds ¶
func RequestAndProcessXds(dr *discovery.DiscoveryRequest, centralOpts clioptions.CentralControlPlaneOptions, istioNamespace string, kubeClient kube.CLIClient) (*discovery.DiscoveryResponse, error)
RequestAndProcessXds merges XDS responses from 1 central or 1..N K8s cluster-based XDS servers Deprecated This method makes multiple responses appear to come from a single control plane; consider using AllRequestAndProcessXds or FirstRequestAndProcessXds nolint: lll
Types ¶
type ControlPlaneNotFoundError ¶
type ControlPlaneNotFoundError struct {
Namespace string
}
func (ControlPlaneNotFoundError) Error ¶
func (c ControlPlaneNotFoundError) Error() string
type Options ¶
type Options struct {
// MessageWriter is a writer for displaying messages to users.
MessageWriter io.Writer
// XdsViaAgents accesses Istiod via the tap service of each agent.
// This is only used in `proxy-status` command.
XdsViaAgents bool
// XdsViaAgentsLimit is the maximum number of pods being visited by istioctl,
// when `XdsViaAgents` is true. This is only used in `proxy-status` command.
// 0 means that there is no limit.
XdsViaAgentsLimit int
}
Source Files
Click to show internal directories.
Click to hide internal directories.