v1

package

Go to main page

Versions in this module

v1

v1.3.4

Dec 22, 2024

Changes in this version

type AdaptiveTimeoutSpec

+ DisableClientQueuing bool

v1.3.3

Dec 17, 2024

v1.3.1

Dec 15, 2024

v1.3.0

Dec 15, 2024

Changes in this version

type AdaptiveTimeoutSpec

+ MinTimeout string

type CircuitBreakerSpec

+ Enabled bool

type ClusterConfig

+ Deployment DeploymentSpec

+ Resiliency ResiliencySpec

type ResiliencySpec

+ LogCallError bool

+ LogTaskError bool

type RetrySpec

+ Enabled bool

v1.2.1-beta.2

Dec 14, 2024

v1.2.1-beta.1

Dec 14, 2024

v1.2.0

Dec 11, 2024

Changes in this version

type ClusterConfig

+ AdaptiveTimeout AdaptiveTimeoutSpec

+ BaseTimeout string

+ func (cc *ClusterConfig) GetBaseTimeout() (time.Duration, error)

type PrimaryAdapterSpec

+ func (pas *PrimaryAdapterSpec) Type() PrimaryAdapterType

+ type PrimaryAdapterType int64

+ const Consumer

+ const Repository

+ const Server

type SecondaryAdapterConfig

+ func (sac *SecondaryAdapterConfig) Type() SecondaryAdapterType

+ type SecondaryAdapterType int64

+ const Invocation

+ const Producer

+ const RepositoryClient

+ const Stressor

v1.1.5

Dec 10, 2024

Changes in this version

type AdaptiveTimeoutSpec

+ OverloadDrainIntervals uint64

v1.1.4

Dec 9, 2024

v1.1.3

Dec 5, 2024

v1.1.2

Dec 4, 2024

Changes in this version

type AdaptiveTimeoutSpec

+ FailureRateSLO float64

+ LatencySLO string

+ OverloadDetectionTiming string

+ func (ats *AdaptiveTimeoutSpec) GetFailureRateSLO() float64

+ func (ats *AdaptiveTimeoutSpec) GetLatencySLO() time.Duration

v1.1.1

Dec 3, 2024

v1.1.1-beta.3

Nov 29, 2024

v1.1.1-beta.2

Nov 28, 2024

v1.1.1-beta.1

Nov 28, 2024

v1.1.0

Nov 27, 2024

Changes in this version

type ClusterConfig

+ ServiceMonitor bool

v1.1.0-beta.3

Nov 27, 2024

v1.1.0-beta.2

Nov 26, 2024

v1.1.0-beta.1

Nov 26, 2024

v1.1.0-beta

Nov 26, 2024

v1.0.32

Nov 25, 2024

v1.0.31

Nov 23, 2024

v1.0.29

Nov 9, 2024

Changes in this version

type AdaptiveTimeoutSpec

+ KMargin int64

v1.0.28

Nov 7, 2024

v1.0.27

Nov 7, 2024

v1.0.26

Nov 7, 2024

v1.0.25

Nov 6, 2024

v1.0.24

Nov 5, 2024

Changes in this version

type AdaptiveTimeoutSpec

+ Capacity int64

+ SLO float64

v1.0.23

Nov 4, 2024

Changes in this version

type AdaptiveTimeoutSpec

+ Enabled bool

+ RTO bool

+ RTOMargin int64

v1.0.22

Oct 28, 2024

v1.0.22-test

Oct 28, 2024

v1.0.21

Oct 11, 2024

v1.0.20

Oct 3, 2024

v1.0.19

Sep 26, 2024

v1.0.18

Sep 22, 2024

Changes in this version

+ var DEFAULT_ADAPTIVE_TIMEOUT_DEC_BY time.Duration = time.Minute

+ var DEFAULT_ADAPTIVE_TIMEOUT_INTERVAL time.Duration = time.Minute

+ var DEFAULT_ADAPTIVE_TIMEOUT_INTITIAL_TIMEOUT time.Duration = 10 * time.Second

+ var DEFAULT_ADAPTIVE_TIMEOUT_MAX time.Duration = time.Minute

+ var DEFAULT_ADAPTIVE_TIMEOUT_MIN time.Duration = time.Millisecond

+ type AdaptiveTimeoutSpec struct

+ DecBy string

+ IncBy float32

+ InitialTimeout string

+ Interval string

+ Max string

+ Min string

+ MinimumCount uint32

+ Threshold float32

+ func (ats *AdaptiveTimeoutSpec) GetDecBy() time.Duration

+ func (ats *AdaptiveTimeoutSpec) GetInitialTimeout() time.Duration

+ func (ats *AdaptiveTimeoutSpec) GetInterval() time.Duration

+ func (ats *AdaptiveTimeoutSpec) GetMax() time.Duration

+ func (ats *AdaptiveTimeoutSpec) GetMin() time.Duration

type ResiliencySpec

+ AdaptiveCallTimeout AdaptiveTimeoutSpec

+ AdaptiveTaskTimeout AdaptiveTimeoutSpec

v1.0.17

Aug 30, 2024

v1.0.16

Aug 30, 2024

v1.0.15

Aug 22, 2024

v1.0.14

Aug 18, 2024

Changes in this version

type ClusterConfig

+ HealthPort int32

type DeploymentSpec

+ DisableReadinessProbe bool

v1.0.13

Aug 17, 2024

Changes in this version

type StressorConfig

+ func (iac *StressorConfig) GetGroupByKey() string

v1.0.10

Aug 15, 2024

Changes in this version

+ var DEFAULT_CALL_TIMEOUT = 2 * time.Second

+ var DEFAULT_CIRCUIT_BREAKER_INTERVAL time.Duration = time.Minute

+ var DEFAULT_CIRCUIT_BREAKER_TIMEOUT time.Duration = time.Minute

+ var DEFAULT_RETRY_INITIAL_BACKOFF time.Duration = time.Millisecond

+ var DEFAULT_TASK_TIMEOUT = 5 * time.Second

+ type CircuitBreakerSpec struct

+ ConsecutiveFails uint32

+ CountRetries bool

+ Disabled bool

+ Interval string

+ MaxRequests uint32

+ MinRequests uint32

+ Ratio float64

+ Timeout string

+ func (cbs *CircuitBreakerSpec) GetInterval() time.Duration

+ func (cbs *CircuitBreakerSpec) GetTimeout() time.Duration

+ type ClusterConfig struct

+ DockerHubUsername string

+ GRPCPort int32

+ HTTPPort int32

+ Kafka KafkaClusterConfig

+ LogLevel string

+ MetricsPort int32

+ Mongo MongoClusterConfig

+ Namespace string

+ Otel OtelCollectorClusterConfig

+ Redis RedisClusterConfig

+ Tracing TracingClusterConfig

+ func NewClusterConfig() ClusterConfig

+ type ConfigKind string

+ var ClusterConfigKind ConfigKind = "ClusterConfig"

+ var ServiceUnitKind ConfigKind = "ServiceUnit"

+ type ConfigTemplate struct

+ ApiVersion string

+ Kind ConfigKind

type DeploymentSpec

+ EnableTopologySpreadConstraint bool

+ type KafkaClusterConfig struct

+ ClusterName string

+ Namespace string

+ Partitions int32

+ Port int32

+ Replications int32

+ type MongoClusterConfig struct

+ ImageName string

+ Password string

+ Port int32

+ Username string

+ type OtelCollectorClusterConfig struct

+ Name string

+ Namespace string

+ Port int32

type PrimaryAdapterSpec

+ TaskSpecs []TaskSpec

+ type RedisClusterConfig struct

+ ImageName string

+ Port int32

+ type ResiliencySpec struct

+ CallTimeout string

+ CircutBreaker CircuitBreakerSpec

+ IsCritical bool

+ Retry RetrySpec

+ TaskTimeout string

+ func (r ResiliencySpec) GetCallTimeout() time.Duration

+ func (r ResiliencySpec) GetTaskTimeout() time.Duration

+ type RetryBackoffPolicy = string

+ const CONSTANT_BACKOFF

+ const EXPONENTIAL_BACKOFF

+ const LINEAR_BACKOFF

+ const NO_BACKOFF

+ type RetrySpec struct

+ BackoffPolicy RetryBackoffPolicy

+ Disabled bool

+ InitialBackoff string

+ MaxAttempt int

+ func (rs *RetrySpec) GetInitialBackoff() time.Duration

+ func (rs *RetrySpec) GetNthBackoff(n int) time.Duration

type StressorConfig

+ Iterations int

+ type TaskSpec struct

+ AdapterConfig *SecondaryAdapterConfig

+ Concurrent bool

+ Resiliency ResiliencySpec

+ type TracingClusterConfig struct

+ Enabled bool

v1.0.0

Nov 16, 2023

Changes in this version

+ func GetPayloadSize(payloadSpec PayloadSpec) int64

+ func GetPayloadVariant(payloadSpec PayloadSpec) constants.PayloadSizeVariant

+ func ParseResource(payloadSpec PayloadSpec) (int64, bool)

+ type ConsumerConfig struct

+ Topic string

+ Variant constants.BrokerVariant

+ func (bac *ConsumerConfig) GetConsumerGroupId(serviceName string) string

+ func (bac *ConsumerConfig) GetGroupByKey() string

+ func (bac *ConsumerConfig) GetId(serviceName string) string

+ type DeploymentSpec struct

+ EnvVar []corev1.EnvVar

+ Gateway *Gateway

+ Replicas int32

+ Resource *corev1.ResourceRequirements

+ type Gateway struct

+ Duration int32

+ VirtualUsers int32

+ type InvocationConfig struct

+ Action constants.Action

+ Payload PayloadSpec

+ Route string

+ Service string

+ Variant constants.SeverAdapterVariant

+ func (sac *InvocationConfig) GetGroupByKey() string

+ func (sac *InvocationConfig) GetId() string

+ type PayloadSpec struct

+ Count int

+ Size string

+ Variant constants.PayloadSizeVariant

+ type PrimaryAdapterSpec struct

+ ConsumerConfig *ConsumerConfig

+ RepositoryConfig *RepositoryConfig

+ Selector *metav1.LabelSelector

+ ServerConfig *ServerConfig

+ Steps []Step

+ func (ias *PrimaryAdapterSpec) GetGroupByKey() string

+ func (ias *PrimaryAdapterSpec) GetId(serviceName string) string

+ type ProducerConfig struct

+ Payload PayloadSpec

+ Topic string

+ Variant constants.BrokerVariant

+ func (bac *ProducerConfig) GetGroupByKey() string

+ func (bac *ProducerConfig) GetId() string

+ type RepositoryClientConfig struct

+ Action constants.Action

+ Name string

+ Payload PayloadSpec

+ Variant constants.RepositoryVariant

+ func (sac *RepositoryClientConfig) GetGroupByKey() string

+ func (sac *RepositoryClientConfig) GetId() string

+ type RepositoryConfig struct

+ Variant constants.RepositoryVariant

+ func (rac *RepositoryConfig) GetGroupByKey() string

+ func (sac *RepositoryConfig) GetId(serviceName string) string

+ type SecondaryAdapterConfig struct

+ InvocationConfig *InvocationConfig

+ ProducerConfig *ProducerConfig

+ RepositoryConfig *RepositoryClientConfig

+ StressorConfig *StressorConfig

+ func (sac *SecondaryAdapterConfig) GetId() string

+ func (sac SecondaryAdapterConfig) GetGroupByKey() string

+ type ServerConfig struct

+ Action constants.Action

+ Payload PayloadSpec

+ Route string

+ Variant constants.SeverAdapterVariant

+ Weight *int32

+ func (sac *ServerConfig) GetGroupByKey() string

+ func (sac *ServerConfig) GetId(serviceName string) string

+ type ServiceUnitConfig struct

+ AdapterConfigs []PrimaryAdapterSpec

+ DeploymentSpec DeploymentSpec

+ Name string

+ Version string

+ type Step struct

+ AdapterConfig *SecondaryAdapterConfig

+ Concurrent bool

+ type StressorConfig struct

+ Duration string

+ Name string

+ Payload PayloadSpec

+ ThreadCount int

+ Variant constants.StressorValiant

+ func (iac *StressorConfig) GetId() string

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