translations

Documentation

Index

• Constants
• type KubeMapper
  • func (km *KubeMapper) EnvoySnapshotFromKubeSnapshot(snap *snapshot.Snapshot) (*cache.Snapshot, error)
  • func (km *KubeMapper) MapEndpointSliceToLocalityEndpoints(svc *v1.Service, endpointslices []*discoveryv1.EndpointSlice) []types.Resource
  • func (km *KubeMapper) MapServicePortToClusters(svc *v1.Service, port *v1.ServicePort) []types.Resource
  • func (km *KubeMapper) MapServicePortToListeners(svc *v1.Service, port *v1.ServicePort) []types.Resource
• type PortSettings
• type Protocol

Constants

const (
	PROTOCOL_TCP = iota
	PROTOCOL_HTTP
	PROTOCOL_REDIS
)

Types

type KubeMapper

type KubeMapper struct{}

KubeMapper wraps all conversion functions and allows configuring default values.

func (*KubeMapper) EnvoySnapshotFromKubeSnapshot

func (km *KubeMapper) EnvoySnapshotFromKubeSnapshot(snap *snapshot.Snapshot) (*cache.Snapshot, error)

EnvoySnaphsotFromKubeSnapshot generates an Envoy configuration snapshot servable to xDS APIs from Kubernetes Service/EndpointSlices.

func (*KubeMapper) MapEndpointSliceToLocalityEndpoints

func (km *KubeMapper) MapEndpointSliceToLocalityEndpoints(svc *v1.Service, endpointslices []*discoveryv1.EndpointSlice) []types.Resource

MapEndpointSliceToLocalityEndpoints maps endpointslices to a cluster load assignment.

func (*KubeMapper) MapServicePortToClusters

func (km *KubeMapper) MapServicePortToClusters(svc *v1.Service, port *v1.ServicePort) []types.Resource

MapServicePortToClusters creates a cluster for each service and ipfamily

func (*KubeMapper) MapServicePortToListeners

func (km *KubeMapper) MapServicePortToListeners(svc *v1.Service, port *v1.ServicePort) []types.Resource

MapServicePortToListeners creats a virtual listener for each IP:port combination

type PortSettings

type PortSettings struct {
	// Port protocol
	Protocol Protocol

	// Listener timeout
	IdleTimeout    time.Duration
	RequestTimeout time.Duration

	// Upstream timeouts
	UpstreamRequestTimeout time.Duration
	UpstreamIdleTimeout    time.Duration
	UpstreamConnectTimeout time.Duration

	// Retires
	EnableRetry bool
	RetryOn     string
	NumRetries  uint32

	// Circuit Breaking
	CircuitBreakerDefaultMaxConnections     uint32
	CircuitBreakerDefaultMaxPendingRequests uint32
	CircuitBreakerDefaultMaxRequests        uint32
	CircuitBreakerDefaultMaxRetries         uint32
	CircuitBreakerDefaultTrackRemaining     bool
	CircuitBreakerHighMaxConnections        uint32
	CircuitBreakerHighMaxPendingRequests    uint32
	CircuitBreakerHighMaxRequests           uint32
	CircuitBreakerHighMaxRetries            uint32
	CircuitBreakerHighTrackRemaining        bool

	// Outlier Detection
	OutlierDetectionInterval                  time.Duration
	OutlierDetectionBaseEjectionTime          time.Duration
	OutlierDetectionMaxEjectionTime           time.Duration
	OutlierDetectionMaxEjectionPercent        uint32
	OutlierDetectionConsecutive5xx            uint32
	OutlierDetectionConsecutiveGatewayFailure uint32

	// AccessLog
	AccessLog bool

	// Loadbalancing algorithm
	LoadBalancingPolicy cluster.Cluster_LbPolicy
}

type Protocol

type Protocol int

Protocol is used to determine the protocol based on the k8s port name.