clusters

Documentation

Index

• type ClusterBuilder
  • func NewClusterBuilder(apiVersion envoy.APIVersion) *ClusterBuilder
  • func (b *ClusterBuilder) Build() (envoy.NamedResource, error)
  • func (b *ClusterBuilder) Configure(opts ...ClusterBuilderOpt) *ClusterBuilder
• type ClusterBuilderConfig
  • func (c *ClusterBuilderConfig) AddV3(configurer v3.ClusterConfigurer)
• type ClusterBuilderOpt
  • func CircuitBreaker(circuitBreaker *mesh_core.CircuitBreakerResource) ClusterBuilderOpt
  • func ClientSideMTLS(ctx xds_context.Context, metadata *core_xds.DataplaneMetadata, ...) ClusterBuilderOpt
  • func ClientSideTLS(endpoints []core_xds.Endpoint) ClusterBuilderOpt
  • func DNSCluster(name string, address string, port uint32) ClusterBuilderOpt
  • func DefaultTimeout() ClusterBuilderOpt
  • func EdsCluster(name string) ClusterBuilderOpt
  • func HealthCheck(protocol mesh_core.Protocol, healthCheck *mesh_core.HealthCheckResource) ClusterBuilderOpt
  • func Http() ClusterBuilderOpt
  • func Http2() ClusterBuilderOpt
  • func LB(lb *mesh_proto.TrafficRoute_LoadBalancer) ClusterBuilderOpt
  • func OutlierDetection(circuitBreaker *mesh_core.CircuitBreakerResource) ClusterBuilderOpt
  • func PassThroughCluster(name string) ClusterBuilderOpt
  • func StaticCluster(name string, address string, port uint32) ClusterBuilderOpt
  • func StaticClusterUnixSocket(name string, path string) ClusterBuilderOpt
  • func StrictDNSCluster(name string, endpoints []core_xds.Endpoint, hasIPv6 bool) ClusterBuilderOpt
  • func Timeout(protocol mesh_core.Protocol, conf *mesh_proto.Timeout_Conf) ClusterBuilderOpt
  • func UnknownDestinationClientSideMTLS(ctx xds_context.Context, metadata *core_xds.DataplaneMetadata) ClusterBuilderOpt
  • func UpstreamBindConfig(address string, port uint32) ClusterBuilderOpt
• type ClusterBuilderOptFunc
  • func LbSubset(tagSets envoy.TagKeysSlice) ClusterBuilderOptFunc
  • func (f ClusterBuilderOptFunc) ApplyTo(config *ClusterBuilderConfig)

Types

type ClusterBuilder

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

ClusterBuilder is responsible for generating an Envoy cluster by applying a series of ClusterConfigurers.

func NewClusterBuilder

func NewClusterBuilder(apiVersion envoy.APIVersion) *ClusterBuilder

func (*ClusterBuilder) Build

func (b *ClusterBuilder) Build() (envoy.NamedResource, error)

Build generates an Envoy cluster by applying a series of ClusterConfigurers.

func (*ClusterBuilder) Configure

func (b *ClusterBuilder) Configure(opts ...ClusterBuilderOpt) *ClusterBuilder

Configure configures ClusterBuilder by adding individual ClusterConfigurers.

type ClusterBuilderConfig

type ClusterBuilderConfig struct {
	// A series of ClusterConfigurers to apply to Envoy cluster.
	ConfigurersV3 []v3.ClusterConfigurer
}

ClusterBuilderConfig holds configuration of a ClusterBuilder.

func (*ClusterBuilderConfig) AddV3

func (c *ClusterBuilderConfig) AddV3(configurer v3.ClusterConfigurer)

Add appends a given ClusterConfigurer to the end of the chain.

type ClusterBuilderOpt

type ClusterBuilderOpt interface {
	// ApplyTo adds ClusterConfigurer(s) to the ClusterBuilder.
	ApplyTo(config *ClusterBuilderConfig)
}

ClusterBuilderOpt is a configuration option for ClusterBuilder.

The goal of ClusterBuilderOpt is to facilitate fluent ClusterBuilder API.

func CircuitBreaker

func CircuitBreaker(circuitBreaker *mesh_core.CircuitBreakerResource) ClusterBuilderOpt

func ClientSideMTLS

func ClientSideMTLS(ctx xds_context.Context, metadata *core_xds.DataplaneMetadata, clientService string, tags []envoy.Tags) ClusterBuilderOpt

func ClientSideTLS

func ClientSideTLS(endpoints []core_xds.Endpoint) ClusterBuilderOpt

func DNSCluster

func DNSCluster(name string, address string, port uint32) ClusterBuilderOpt

func DefaultTimeout

func DefaultTimeout() ClusterBuilderOpt

func EdsCluster

func EdsCluster(name string) ClusterBuilderOpt

func HealthCheck

func HealthCheck(protocol mesh_core.Protocol, healthCheck *mesh_core.HealthCheckResource) ClusterBuilderOpt

func Http

func Http() ClusterBuilderOpt

func Http2

func Http2() ClusterBuilderOpt

func LB

func LB(lb *mesh_proto.TrafficRoute_LoadBalancer) ClusterBuilderOpt

func OutlierDetection

func OutlierDetection(circuitBreaker *mesh_core.CircuitBreakerResource) ClusterBuilderOpt

func PassThroughCluster

func PassThroughCluster(name string) ClusterBuilderOpt

func StaticCluster

func StaticCluster(name string, address string, port uint32) ClusterBuilderOpt

func StaticClusterUnixSocket

func StaticClusterUnixSocket(name string, path string) ClusterBuilderOpt

func StrictDNSCluster

func StrictDNSCluster(name string, endpoints []core_xds.Endpoint, hasIPv6 bool) ClusterBuilderOpt

func Timeout

func Timeout(protocol mesh_core.Protocol, conf *mesh_proto.Timeout_Conf) ClusterBuilderOpt

func UnknownDestinationClientSideMTLS

func UnknownDestinationClientSideMTLS(ctx xds_context.Context, metadata *core_xds.DataplaneMetadata) ClusterBuilderOpt

UnknownDestinationClientSideMTLS configures cluster with mTLS for a mesh but without extensive destination verification (only Mesh is verified)

func UpstreamBindConfig

func UpstreamBindConfig(address string, port uint32) ClusterBuilderOpt

type ClusterBuilderOptFunc

type ClusterBuilderOptFunc func(config *ClusterBuilderConfig)

ClusterBuilderOptFunc is a convenience type adapter.

func LbSubset

func LbSubset(tagSets envoy.TagKeysSlice) ClusterBuilderOptFunc

LbSubset is required for MetadataMatch in Weighted Cluster in TCP Proxy to work. Subset loadbalancing is used in two use cases

1. TrafficRoute for splitting traffic. Example: TrafficRoute that splits 10% of the traffic to version 1 of the service backend and 90% traffic to version 2 of the service backend
2. Multiple outbound sections with the same service Example: type: Dataplane networking: outbound: - port: 1234 tags: kuma.io/service: backend - port: 1234 tags: kuma.io/service: backend version: v1 Only one cluster "backend" is generated for such dataplane, but with lb subset by version.

func (ClusterBuilderOptFunc) ApplyTo

func (f ClusterBuilderOptFunc) ApplyTo(config *ClusterBuilderConfig)