utils

Documentation

Index

• func DurationFromProto(p *types.Duration) (time.Duration, error)
• func DurationProto(d time.Duration) *types.Duration
• func GetHostForUpstream(us *gloov1.Upstream) (string, error)
• func GetHostsForUpstream(us *gloov1.Upstream) ([]string, error)
• func GetLabelsForUpstream(us *gloov1.Upstream) map[string]string
• func GetNamespaceForUpstream(us *gloov1.Upstream) string
• func GetPortForUpstream(us *gloov1.Upstream) (uint32, error)
• func HostsForUpstreams(upstreams gloov1.UpstreamList) ([]string, error)
• func LabelsAndPortsByHost(upstreams gloov1.UpstreamList) (map[string][]LabelsPortTuple, error)
• func PodsForSelector(selector *v1.PodSelector, upstreams gloov1.UpstreamList, allPods v1.PodList) (v1.PodList, error)
• func PodsForUpstreams(upstreams gloov1.UpstreamList, allPods v1.PodList) (v1.PodList, error)
• func RuleAppliesToDestination(destinationHost string, destinationSelector *v1.PodSelector, ...) (bool, error)
• func SubsetName(labels map[string]string) string
• func UpstreamsForSelector(selector *v1.PodSelector, allUpstreams gloov1.UpstreamList) (gloov1.UpstreamList, error)
• func ValidateMeshGroups(meshes v1.MeshList, meshGroups v1.MeshGroupList, ...)
• type LabelsPortTuple
• type RuleSet
• type RulesByMatcher
  • func NewRulesByMatcher(rules v1.RoutingRuleList) RulesByMatcher
  • func (rbm RulesByMatcher) Sort() []v1.RoutingRuleList
• type RulesByMesh
  • func GroupRulesByMesh(routingRules v1.RoutingRuleList, securityRules v1.SecurityRuleList, ...) RulesByMesh

Functions

func DurationFromProto

func DurationFromProto(p *types.Duration) (time.Duration, error)

DurationFromProto converts a Duration to a time.Duration. DurationFromProto returns an error if the Duration is invalid or is too large to be represented in a time.Duration.

func DurationProto

func DurationProto(d time.Duration) *types.Duration

DurationProto converts a time.Duration to a Duration.

func GetHostForUpstream

func GetHostForUpstream(us *gloov1.Upstream) (string, error)

func GetHostsForUpstream

func GetHostsForUpstream(us *gloov1.Upstream) ([]string, error)

func GetLabelsForUpstream

func GetLabelsForUpstream(us *gloov1.Upstream) map[string]string

func GetNamespaceForUpstream

func GetNamespaceForUpstream(us *gloov1.Upstream) string

func GetPortForUpstream

func GetPortForUpstream(us *gloov1.Upstream) (uint32, error)

func HostsForUpstreams

func HostsForUpstreams(upstreams gloov1.UpstreamList) ([]string, error)

func LabelsAndPortsByHost

func LabelsAndPortsByHost(upstreams gloov1.UpstreamList) (map[string][]LabelsPortTuple, error)

func PodsForSelector

func PodsForSelector(selector *v1.PodSelector, upstreams gloov1.UpstreamList, allPods v1.PodList) (v1.PodList, error)

func PodsForUpstreams

func PodsForUpstreams(upstreams gloov1.UpstreamList, allPods v1.PodList) (v1.PodList, error)

func RuleAppliesToDestination

func RuleAppliesToDestination(destinationHost string, destinationSelector *v1.PodSelector, upstreams gloov1.UpstreamList) (bool, error)

func SubsetName

func SubsetName(labels map[string]string) string

func UpstreamsForSelector

func UpstreamsForSelector(selector *v1.PodSelector, allUpstreams gloov1.UpstreamList) (gloov1.UpstreamList, error)

func ValidateMeshGroups

func ValidateMeshGroups(meshes v1.MeshList, meshGroups v1.MeshGroupList, resourceErrs reporter.ResourceErrors)

Types

type LabelsPortTuple

type LabelsPortTuple struct {
	Labels map[string]string
	Port   uint32
}

type RuleSet

type RuleSet struct {
	Routing  v1.RoutingRuleList
	Security v1.SecurityRuleList
}

type RulesByMatcher

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

we create a routing rule for each unique matcher

func NewRulesByMatcher

func NewRulesByMatcher(rules v1.RoutingRuleList) RulesByMatcher

func (RulesByMatcher) Sort

func (rbm RulesByMatcher) Sort() []v1.RoutingRuleList

type RulesByMesh

type RulesByMesh map[*v1.Mesh]RuleSet

func GroupRulesByMesh

func GroupRulesByMesh(
	routingRules v1.RoutingRuleList,
	securityRules v1.SecurityRuleList,
	meshes v1.MeshList,
	meshGroups v1.MeshGroupList,
	resourceErrs reporter.ResourceErrors) RulesByMesh