multixds

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
  • func (c ControlPlaneNotFoundError) Error() string
• type Options

Variables

var DefaultOptions = Options{
	MessageWriter:     os.Stdout,
	XdsViaAgents:      false,
	XdsViaAgentsLimit: 0,
}

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
}