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 GetUpstreamHostPortsLabels(us *gloov1.Upstream) (string, uint32, map[string]string, error)
• func GetUpstreamKubeSpec(us *gloov1.Upstream) (*kubernetes.UpstreamSpec, error)
• func HostnameSelected(hostname string, selector *v1.PodSelector, upstreams gloov1.UpstreamList) (bool, error)
• func HostsForUpstreams(upstreams gloov1.UpstreamList) ([]string, error)
• func LabelsFromUpstreams(upstreams gloov1.UpstreamList) ([]map[string]string, error)
• func PodsForSelector(selector *v1.PodSelector, upstreams gloov1.UpstreamList, ...) (kubernetes.PodList, error)
• func PodsForUpstreams(upstreams gloov1.UpstreamList, allPods kubernetes.PodList) kubernetes.PodList
• func PortsFromUpstreams(upstreams gloov1.UpstreamList) ([]uint32, error)
• func ServiceHost(serviceName, serviceNamespace string) string
• func ServicesForSelector(selector *v1.PodSelector, upstreams gloov1.UpstreamList, ...) (kubernetes.ServiceList, error)
• func ServicesForUpstreams(upstreams gloov1.UpstreamList, allServices kubernetes.ServiceList) kubernetes.ServiceList
• func SubsetName(labels map[string]string) string
• func UpstreamServicesByHost(upstreams gloov1.UpstreamList) (map[string]*UpstreamService, error)
• func UpstreamsForPods(pods kubernetes.PodList, allUpstreams gloov1.UpstreamList) gloov1.UpstreamList
• func UpstreamsForSelector(selector *v1.PodSelector, allUpstreams gloov1.UpstreamList) (gloov1.UpstreamList, error)
• func ValidateMeshGroups(meshes v1.MeshList, meshGroups v1.MeshGroupList, ...)
• type RuleSet
• type RulesByMesh
  • func GroupRulesByMesh(routingRules v1.RoutingRuleList, securityRules v1.SecurityRuleList, ...) RulesByMesh
• type UpstreamService
  • func ServiceFromHost(host string, upstreams gloov1.UpstreamList) (*UpstreamService, error)

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 GetUpstreamHostPortsLabels

func GetUpstreamHostPortsLabels(us *gloov1.Upstream) (string, uint32, map[string]string, error)

func GetUpstreamKubeSpec

func GetUpstreamKubeSpec(us *gloov1.Upstream) (*kubernetes.UpstreamSpec, error)

func HostnameSelected

func HostnameSelected(hostname string, selector *v1.PodSelector, upstreams gloov1.UpstreamList) (bool, error)

func HostsForUpstreams

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

func LabelsFromUpstreams

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

func PodsForSelector

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

func PodsForUpstreams

func PodsForUpstreams(upstreams gloov1.UpstreamList, allPods kubernetes.PodList) kubernetes.PodList

func PortsFromUpstreams

func PortsFromUpstreams(upstreams gloov1.UpstreamList) ([]uint32, error)

func ServiceHost

func ServiceHost(serviceName, serviceNamespace string) string

TODO (ilackarms): consider multi-cluster here

func ServicesForSelector

func ServicesForSelector(selector *v1.PodSelector, upstreams gloov1.UpstreamList, allServices kubernetes.ServiceList) (kubernetes.ServiceList, error)

func ServicesForUpstreams

func ServicesForUpstreams(upstreams gloov1.UpstreamList, allServices kubernetes.ServiceList) kubernetes.ServiceList

func SubsetName

func SubsetName(labels map[string]string) string

func UpstreamServicesByHost

func UpstreamServicesByHost(upstreams gloov1.UpstreamList) (map[string]*UpstreamService, error)

func UpstreamsForPods

func UpstreamsForPods(pods kubernetes.PodList, allUpstreams gloov1.UpstreamList) gloov1.UpstreamList

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 RuleSet

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

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

type UpstreamService

type UpstreamService struct {
	Host      string
	LabelSets []map[string]string
	Ports     []uint32
	Upstreams gloov1.UpstreamList // the upstreams this service was created from
}

one (kube) service that maps to multiple upstreams

func ServiceFromHost

func ServiceFromHost(host string, upstreams gloov1.UpstreamList) (*UpstreamService, error)

only selects the first upstream in each list with a unique host, drop the others