resource

Documentation

Overview

Package resource creates test xDS resources

Index

• Constants
• Variables
• func MakeCluster(mode string, clusterName string) *v2.Cluster
• func MakeEndpoint(clusterName string, port uint32) *v2.ClusterLoadAssignment
• func MakeHTTPListener(mode string, listenerName string, port uint32, route string) *v2.Listener
• func MakeRoute(routeName, clusterName string) *v2.RouteConfiguration
• func MakeTCPListener(listenerName string, port uint32, clusterName string) *v2.Listener
• type TestSnapshot
  • func (ts TestSnapshot) Generate() cache.Snapshot

Constants

const (

	// XdsCluster is the cluster name for the control server (used by non-ADS set-up)
	XdsCluster = "xds_cluster"

	// Ads mode for resources: one aggregated xDS service
	Ads = "ads"

	// Xds mode for resources: individual xDS services
	Xds = "xds"

	// Rest mode for resources: polling using Fetch
	Rest = "rest"
)

Variables

var (
	// RefreshDelay for the polling config source
	RefreshDelay = 500 * time.Millisecond
)

Functions

func MakeCluster

func MakeCluster(mode string, clusterName string) *v2.Cluster

MakeCluster creates a cluster using either ADS or EDS.

func MakeEndpoint

func MakeEndpoint(clusterName string, port uint32) *v2.ClusterLoadAssignment

MakeEndpoint creates a localhost endpoint on a given port.

func MakeHTTPListener

func MakeHTTPListener(mode string, listenerName string, port uint32, route string) *v2.Listener

MakeHTTPListener creates a listener using either ADS or RDS for the route.

func MakeRoute

func MakeRoute(routeName, clusterName string) *v2.RouteConfiguration

MakeRoute creates an HTTP route that routes to a given cluster.

func MakeTCPListener

func MakeTCPListener(listenerName string, port uint32, clusterName string) *v2.Listener

MakeTCPListener creates a TCP listener for a cluster.

Types

type TestSnapshot

type TestSnapshot struct {
	// Xds indicates snapshot mode: ads, xds, or rest
	Xds string
	// Version for the snapshot.
	Version string
	// UpstreamPort for the single endpoint on the localhost.
	UpstreamPort uint32
	// BasePort is the initial port for the listeners.
	BasePort uint32
	// NumClusters is the total number of clusters to generate.
	NumClusters int
	// NumHTTPListeners is the total number of HTTP listeners to generate.
	NumHTTPListeners int
	// NumTCPListeners is the total number of TCP listeners to generate.
	// Listeners are assigned clusters in a round-robin fashion.
	NumTCPListeners int
}

TestSnapshot holds parameters for a synthetic snapshot.

func (TestSnapshot) Generate

func (ts TestSnapshot) Generate() cache.Snapshot

Generate produces a snapshot from the parameters.