uxds

type ADSC struct {

	// InitialLoad tracks the time to receive the initial configuration.
	InitialLoad time.Duration

	// HTTPListeners contains received listeners with a http_connection_manager filter.
	HTTPListeners map[string]*xds.Listener

	// TCPListeners contains all listeners of type TCP (not-HTTP)
	TCPListeners map[string]*xds.Listener

	// All received Clusters of no-eds type, keyed by name
	Clusters map[string]*xds.Cluster

	// All received Routes, keyed by route name
	Routes map[string]*xds.RouteConfiguration

	// All received endpoints, keyed by cluster name
	Endpoints map[string]*xds.ClusterLoadAssignment

	// Metadata has the node metadata to send to pilot.
	// If nil, the defaults will be used.
	Metadata map[string]interface{}
	Config   *Config

	// Updates includes the type of the last update received from the server, or "close".
	// Short names for eds/cds/lds/rds, as well as init, error-xxxx, long names for other types.
	Updates chan string

	XDSUpdates chan *xds.DiscoveryResponse

	VersionInfo map[string]string

	// Last received message, by type
	Received map[string]*xds.DiscoveryResponse

	// LocalCacheDir is set to a base name used to save fetched resources.
	// If set, each update will be saved.
	// TODO: also load at startup - so we can support warm up in init-container, and survive
	// restarts.
	LocalCacheDir string

	// RecvWg is for letting goroutines know when the goroutine handling the ADS stream finishes.
	RecvWg sync.WaitGroup
	// contains filtered or unexported fields
}

type Config struct {
	// Namespace defaults to 'default'
	Namespace string

	// Workload defaults to 'test'
	Workload string

	// Revision for this control plane instance. We will only read configs that match this revision.
	Revision string

	// Meta includes additional metadata for the node
	Meta map[string]interface{}

	Locality *xds.Locality

	XDSHeaders map[string]string

	// NodeType defaults to sidecar. "ingress" and "router" are also supported.
	NodeType string

	// IP is currently the primary key used to locate inbound configs. It is sent by client,
	// must match a known endpoint IP. Tests can use a ServiceEntry to register fake IPs.
	IP string

	// Context used for early cancellation
	Context context.Context

	NodeId string

	// InitialDiscoveryRequests is a list of resources to watch at first, represented as URLs (for new XDS resource naming)
	// or type URLs.
	InitialDiscoveryRequests []*xds.DiscoveryRequest

	// ResponseHandler will be called on each DiscoveryResponse.
	// TODO: mirror Generator, allow adding handler per type
	ResponseHandler func(con *ADSC, response *xds.DiscoveryResponse)

	HBone   *hbone.HBone
	Cluster *hbone.Cluster
}

type Endpoint struct {
	// Weight extracted from EDS
	Weight int
}

type TCPListener struct {
	// Address is the address, as expected by go Dial and Listen, including port
	Address string

	// LogFile is the access log address for the listener
	LogFile string

	// Target is the destination cluster.
	Target string
}

type Target struct {

	// Address is a go address, extracted from the mangled cluster name.
	Address string

	// Endpoints are the resolved endpoints from EDS or cluster static.
	Endpoints map[string]Endpoint
}

type Watch struct {
	// contains filtered or unexported fields
}