topology

package

Go to main page

Versions in this module

v0

v0.15.0

Oct 26, 2023

v0.14.2

Sep 22, 2023

v0.14.1

Sep 22, 2023

v0.14.0

Sep 21, 2023

Changes in this version

+ var ADVERBS = []string

+ var VERBS = []string

type Generator

+ GenerateKey func() string

+ GenerateValue func() string

type Kubernetes

+ func (k *Kubernetes) GetRandomK8sTags() map[string]string

type Metric

+ Random *rand.Rand

+ TagGenerator TagGenerator

+ type RandomTagGenerator struct

+ func (rtg *RandomTagGenerator) GenerateKey() string

+ func (rtg *RandomTagGenerator) GenerateValue() string

type TagGenerator

+ Tags []string

+ ValueVariability int

+ func (t *TagGenerator) GetRefreshedTags() map[string]string

+ func (t *TagGenerator) GetTags() map[string]string

+ func (t *TagGenerator) Init(random *rand.Rand)

v0.13.0

Aug 16, 2023

v0.12.0

May 25, 2023

v0.11.13

Mar 15, 2023

v0.11.12

Mar 3, 2023

v0.11.11

Mar 2, 2023

v0.11.10

Jan 23, 2023

v0.11.9

Jan 5, 2023

v0.11.8

Dec 15, 2022

v0.11.5

Nov 1, 2022

v0.11.4

Oct 26, 2022

Changes in this version

+ const Cluster

+ const Container

+ const DefaultMetricTickerPeriod

+ const DefaultOffset

+ const DefaultPeriod

+ const Deployment

+ const Namespace

+ const PodName

+ const ReplicaSet

+ const Service

+ var ADJECTIVES = []string

+ var NOUNS = []string

+ func AverageValue(_ float64) float64

+ func SawtoothValue(phase float64) float64

+ func SineValue(phase float64) float64

+ func SquareValue(phase float64) float64

+ func TriangleValue(phase float64) float64

+ type Call struct

+ Route string

+ Service string

+ type Config struct

+ Kubernetes *KubernetesConfig

+ type EmbeddedWeight struct

+ Weight float64

+ func (w EmbeddedWeight) GetWeight() float64

+ type File struct

+ Config *Config

+ Flags []flags.FlagConfig

+ RootRoutes []RootRoute

+ Topology *Topology

+ func (file *File) ValidateRootRoutes() error

+ type Generator interface

+ Generate func() string

+ type Kubernetes struct

+ Cfg *Config

+ ClusterName string

+ Deployment string

+ Limit Resource

+ Namespace string

+ PodCount int

+ ReplicaSetName string

+ Request Resource

+ Restart Restart

+ Service string

+ Usage Usage

+ func (k *Kubernetes) CreatePods(serviceName string)

+ func (k *Kubernetes) GenerateMetrics() []Metric

+ func (k *Kubernetes) GetK8sTags() map[string]string

+ func (k *Kubernetes) GetPodCount() int

+ func (k *Kubernetes) RestartDurationWithJitter() time.Duration

+ type KubernetesConfig struct

+ PodCount int

+ type LatencyConfigs []*LatencyPercentiles

+ func (lcfg *LatencyConfigs) Sample() int64

+ type LatencyPercentiles struct

+ P0Cfg string

+ P100Cfg string

+ P50Cfg string

+ P95Cfg string

+ P999Cfg string

+ P99Cfg string

+ func (l *LatencyPercentiles) Sample() int64

+ type Metric struct

+ Jitter float64

+ Max float64

+ Min float64

+ Name string

+ Offset *time.Duration

+ Period *time.Duration

+ Pod *Pod

+ Shape Shape

+ ShapeInterface ShapeInterface

+ Tags map[string]string

+ Type string

+ func (m *Metric) GetTags() map[string]string

+ func (m *Metric) GetValue() float64

+ func (m *Metric) InitMetric()

+ type Pickable interface

+ GetWeight func() float64

+ ShouldGenerate func() bool

+ type Pod struct

+ Container string

+ Kubernetes *Kubernetes

+ PodName string

+ RestartDuration time.Duration

+ StartTime time.Time

+ func (p *Pod) ReplaceTags(tags map[string]string) map[string]string

+ func (p *Pod) RestartIfNeeded(flags flags.EmbeddedFlags, logger *zap.Logger) bool

+ type Resource struct

+ CPU float64

+ Memory float64

+ type ResourceAttributeSet struct

+ Kubernetes *Kubernetes

+ ResourceAttributes TagMap

+ func (r *ResourceAttributeSet) GetAttributes() *TagMap

+ type ResourceUsage struct

+ Jitter float64

+ Target float64

+ type Restart struct

+ Every time.Duration

+ Jitter time.Duration

+ type RootRoute struct

+ Route string

+ Service string

+ TracesPerHour int

+ type ServiceRoute struct

+ DownstreamCalls []Call

+ LatencyConfigs LatencyConfigs

+ MaxLatencyMillis int64

+ Route string

+ TagSets []TagSet

+ func (r *ServiceRoute) SampleLatency() int64

+ type ServiceTier struct

+ Metrics []Metric

+ Random *rand.Rand

+ ResourceAttributeSets []ResourceAttributeSet

+ Routes map[string]*ServiceRoute

+ ServiceName string

+ TagSets []TagSet

+ func (st *ServiceTier) GetResourceAttributeSet() ResourceAttributeSet

+ func (st *ServiceTier) GetRoute(routeName string) *ServiceRoute

+ func (st *ServiceTier) GetTagSet(routeName string) TagSet

+ func (st *ServiceTier) Validate(topology Topology) error

+ type Shape string

+ const Average

+ const Leaking

+ const Sawtooth

+ const Sine

+ const Square

+ const Triangle

+ type ShapeInterface interface

+ GetValue func(phase float64) float64

+ type TagGenerator struct

+ NumTags int

+ NumVals int

+ Random *rand.Rand

+ ValLength int

+ func (t *TagGenerator) GenerateTags() map[string]string

+ type TagMap map[string]interface

+ func (tm *TagMap) InsertTags(attr *pcommon.Map)

+ type TagNameGenerator struct

+ func (rn *TagNameGenerator) Generate() string

+ type TagSet struct

+ CsvTags map[string]string

+ Inherit []string

+ TagGenerators []TagGenerator

+ Tags TagMap

+ type Topology struct

+ Services map[string]*ServiceTier

+ func (t *Topology) GetServiceTier(serviceName string) *ServiceTier

+ func (t *Topology) Load() error

+ func (t *Topology) ValidateServiceGraph(rootRoutes []RootRoute) error

+ type Usage struct

+ CPU ResourceUsage

+ Disk ResourceUsage

+ Memory ResourceUsage

+ Network ResourceUsage

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