topology

Sep 23, 2020

Changes in this version

+ func ResolveServicePort(svcPort corev1.ServicePort, containerPorts []corev1.ContainerPort) (int32, bool)

+ type Builder struct

+ func NewBuilder(serviceLister listers.ServiceLister, endpointLister listers.EndpointsLister, ...) *Builder

+ func (b *Builder) Build(resourceFilter *mk8s.ResourceFilter) (*Topology, error)

+ type Key struct

+ Name string

+ Namespace string

+ func (k *Key) UnmarshalJSON(data []byte) error

+ func (k *Key) UnmarshalText(data []byte) error

+ func (k Key) MarshalText() ([]byte, error)

+ func (k Key) String() string

+ type Pod struct

+ ContainerPorts []corev1.ContainerPort

+ DestinationOf []ServiceTrafficTargetKey

+ IP string

+ Name string

+ Namespace string

+ OwnerReferences []v1.OwnerReference

+ ServiceAccount string

+ SourceOf []ServiceTrafficTargetKey

+ type Service struct

+ Annotations map[string]string

+ BackendOf []Key

+ ClusterIP string

+ Errors []string

+ Name string

+ Namespace string

+ Pods []Key

+ Ports []corev1.ServicePort

+ Selector map[string]string

+ TrafficSplits []Key

+ TrafficTargets []ServiceTrafficTargetKey

+ func (s *Service) AddError(err error)

+ type ServiceTrafficTarget struct

+ Destination ServiceTrafficTargetDestination

+ Errors []string

+ Name string

+ Namespace string

+ Rules []TrafficSpec

+ Service Key

+ Sources []ServiceTrafficTargetSource

+ func (tt *ServiceTrafficTarget) AddError(err error)

+ type ServiceTrafficTargetDestination struct

+ Namespace string

+ Pods []Key

+ Ports []corev1.ServicePort

+ ServiceAccount string

+ type ServiceTrafficTargetKey struct

+ Service Key

+ TrafficTarget Key

+ func (k *ServiceTrafficTargetKey) UnmarshalJSON(data []byte) error

+ func (k *ServiceTrafficTargetKey) UnmarshalText(data []byte) error

+ func (k ServiceTrafficTargetKey) MarshalText() ([]byte, error)

+ func (k ServiceTrafficTargetKey) String() string

+ type ServiceTrafficTargetSource struct

+ Namespace string

+ Pods []Key

+ ServiceAccount string

+ type Topology struct

+ Pods map[Key]*Pod

+ ServiceTrafficTargets map[ServiceTrafficTargetKey]*ServiceTrafficTarget

+ Services map[Key]*Service

+ TrafficSplits map[Key]*TrafficSplit

+ func NewTopology() *Topology

+ type TrafficSpec struct

+ HTTPMatches []*specs.HTTPMatch

+ HTTPRouteGroup *specs.HTTPRouteGroup

+ TCPRoute *specs.TCPRoute

+ type TrafficSplit struct

+ Backends []TrafficSplitBackend

+ Errors []string

+ Incoming []Key

+ Name string

+ Namespace string

+ Rules []TrafficSpec

+ Service Key

+ func (ts *TrafficSplit) AddError(err error)

+ type TrafficSplitBackend struct

+ Service Key

+ Weight int