translations

package

v0.1.0 Latest Latest Go to latest Published: Jul 16, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/xvzf/lightpath

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	PROTOCOL_TCP = iota
	PROTOCOL_HTTP
	PROTOCOL_REDIS
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v0.0.2

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 ¶ added in v0.0.2

type Protocol int

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL