wasp

Apr 11, 2024

Changes in this version

type GrafanaOpts

+ AnnotateDashboardUID string

type Profile

+ ProfileID string

Feb 28, 2024

Changes in this version

+ func CheckDashboardAlerts(grafanaClient *grafana.Client, from, to time.Time, dashboardUIDs []string) ([]grafana.Annotation, error)

type Generator

+ Cfg *Config

+ type GrafanaOpts struct

+ AnnotateDashboardUIDs []string

+ CheckDashboardAlertsAfterRun []string

+ GrafanaToken string

+ GrafanaURL string

+ WaitBeforeAlertCheck time.Duration

type Profile

+ func (m *Profile) WithGrafana(opts *GrafanaOpts) *Profile

Feb 20, 2024

Changes in this version

+ var DefaultDockerIgnorefile []byte

type ClusterConfig

+ DockerIgnoreFilePath string

Feb 19, 2024

Changes in this version

type ClusterConfig

+ DockerCmdExecPath string

Feb 12, 2024

Changes in this version

+ const DefaultLimitsCPU

+ const DefaultLimitsMemory

+ const DefaultRequestsCPU

+ const DefaultRequestsMemory

+ var DefaultBuildScript []byte

+ var DefaultDockerfile []byte

type ClusterConfig

+ BuildCtxPath string

+ BuildScriptPath string

+ DockerfilePath string

+ HelmDeployTimeoutSec string

+ ImageTag string

+ RegistryName string

+ RepoName string

+ UpdateImage bool

Feb 8, 2024

Changes in this version

+ type VUControl struct

+ func NewVUControl() *VUControl

+ func (m *VUControl) Stop(_ *Generator)

+ func (m *VUControl) StopChan() chan struct{}

Jan 17, 2024

Changes in this version

type LokiConfig

+ func DefaultLokiConfig() *LokiConfig

+ func NewLokiConfig(endpoint *string, tenant *string, basicAuth *string, token *string) *LokiConfig

Dec 15, 2023

Changes in this version

+ type Response struct

+ Data interface{}

+ Duration time.Duration

+ Error string

+ Failed bool

+ FinishedAt *time.Time

+ Group string

+ Path string

+ StartedAt *time.Time

+ StatusCode string

+ Timeout bool

Dec 7, 2023

Changes in this version

type LokiClient

+ func (m *LokiClient) StopNow()

type LokiConfig

+ MaxErrors int

type LokiLogWrapper

+ MaxErrors int

+ func NewLokiLogWrapper(maxErrors int) *LokiLogWrapper

Nov 14, 2023

Changes in this version

+ const DefaultSetupTimeout

+ const DefaultTeardownTimeout

+ var ErrSetup = errors.New("generator request setup error")

+ var ErrSetupTimeout = errors.New("generator request setup timeout")

+ var ErrTeardown = errors.New("generator request teardown error")

+ var ErrTeardownTimeout = errors.New("generator request teardown timeout")

type Config

+ SetupTimeout time.Duration

+ TeardownTimeout time.Duration

type MockVirtualUserConfig

+ SetupFailure bool

+ SetupSleep time.Duration

+ TeardownFailure bool

+ TeardownSleep time.Duration

Nov 9, 2023

Changes in this version

+ var ErrInvalidLabels = errors.New("invalid Loki labels, labels should be [a-z][A-Z][0-9] and _")

Oct 2, 2023

Changes in this version

+ var CPUIdleThresholdPercentage = 20

+ var MEMFreeThresholdPercentage = 0

+ var ResourcesThresholdCheckInterval = 5 * time.Second

+ func CPUCheckLoop()

type Config

+ FailOnErr bool

Aug 16, 2023

Changes in this version

type LokiConfig

+ BasicAuth string

Aug 14, 2023

Changes in this version

+ var ErrInvalidSegmentDuration = errors.New("SegmentDuration must be defined")

+ func Max(x, y int64) int64

+ func Min(x, y int64) int64

type Segment

+ Duration time.Duration

+ func Steps(from, increase int64, steps int, duration time.Duration) []*Segment

Jul 24, 2023

Changes in this version

type Generator

+ func (g *Generator) Pause()

+ func (g *Generator) Resume()

type Profile

+ func (m *Profile) Pause()

+ func (m *Profile) Resume()

type Stats

+ RunPaused atomic.Bool

Jul 5, 2023

Changes in this version

type LokiConfig

+ IgnoreErrors bool

+ type LokiLogWrapper struct

+ IgnoreErrors bool

+ func (m *LokiLogWrapper) Log(kvars ...interface{}) error

+ func (m *LokiLogWrapper) SetClient(c *LokiClient)

type Stats

+ CurrentTimeUnit int64

May 18, 2023

Changes in this version

type Profile

+ func (m *Profile) Add(g *Generator, err error) *Profile

May 16, 2023

Changes in this version

type Config

+ SamplerConfig *SamplerConfig

+ type Sampler struct

+ func NewSampler(cfg *SamplerConfig) *Sampler

+ func (m *Sampler) ShouldRecord(cr CallResult, s *Stats) bool

+ type SamplerConfig struct

+ SuccessfulCallResultRecordRatio int

type Stats

+ SamplesRecorded atomic.Int64

+ SamplesSkipped atomic.Int64

May 3, 2023

Changes in this version

type MockGunConfig

+ InternalStop bool

May 2, 2023

Changes in this version

+ const AlertTypeTimeouts

+ func InlineLokiAlertParams(queryType, testName, genName string) string

type Dashboard

+ DataSourceName string

+ Folder string

+ GrafanaToken string

+ GrafanaURL string

+ Name string

+ func (m *Dashboard) Build(dashboardName, datasourceName string, requirements []WaspAlert) error

+ func (m *Dashboard) JSON() ([]byte, error)

May 1, 2023

Changes in this version

+ const CallGroupLabel

+ const K8sStatePollInterval

+ var ErrNoChart = errors.New("cluster chart path is empty")

+ var ErrNoJobs = errors.New("HelmValues should contain \"jobs\" field used to scale your cluster jobs")

+ var ErrNoNamespace = errors.New("namespace is empty")

+ var ErrNoSync = errors.New("HelmValues should contain \"sync\" field used to track your cluster jobs")

+ var ErrNoTimeout = errors.New("timeout shouldn't be zero")

+ func ExecCmd(command string) error

+ func ExecCmdWithStreamFunc(command string, outputFunction func(string)) error

+ func GetLocalK8sDeps() (*kubernetes.Clientset, *rest.Config, error)

type CallResult

+ Group string

+ type ClusterConfig struct

+ ChartPath string

+ HelmValues map[string]string

+ KeepJobs bool

+ Namespace string

+ Timeout time.Duration

+ func (m *ClusterConfig) Defaults()

+ func (m *ClusterConfig) Validate() (err error)

+ type ClusterProfile struct

+ Cancel context.CancelFunc

+ Ctx context.Context

+ func NewClusterProfile(cfg *ClusterConfig) (*ClusterProfile, error)

+ func (m *ClusterProfile) Run() error

type Generator

+ Responses *Responses

+ type K8sClient struct

+ ClientSet *kubernetes.Clientset

+ RESTConfig *rest.Config

+ func NewK8sClient() *K8sClient

+ func (m *K8sClient) TrackJobs(ctx context.Context, nsName, syncLabel string, jobNum int, keepJobs bool) error

type LocalLogger

+ func (m *LocalLogger) SetClient(c *LokiClient)

type Profile

+ func NewProfile(t *testing.T, labels map[string]string, parts interface{}) (*Profile, error)

+ type Responses struct

+ func NewResponses(ch chan CallResult) *Responses

+ func (m *Responses) Err(r *resty.Response, group string, err error)

+ func (m *Responses) OK(r *resty.Response, group string)

Apr 28, 2023

Changes in this version

+ const DefaultRateLimitUnitDuration

+ var ErrInvalidScheduleType = errors.New("schedule type must be either of wasp.RPS, wasp.VU, use package constants")

type Config

+ RateLimitUnitDuration time.Duration

+ type ScheduleType string

+ const RPS

+ const VU

type Stats

+ Duration int64

Apr 20, 2023

Changes in this version

type LokiConfig

+ BackoffConfig backoff.Config

+ DropRateLimitedBatches bool

+ ExposePrometheusMetrics bool

+ Headers map[string]string

+ MaxLineSize int

+ MaxLineSizeTruncate bool

+ MaxStreams int

+ TenantID string

Apr 18, 2023

Changes in this version

+ const DefaultGenName

+ const VUScheduleType

+ var ErrNoSchedule = errors.New("no schedule segments were provided")

+ var ErrNoVU = errors.New("vu load scheduleSegments selected but vu implementation is nil")

type Config

+ VU VirtualUser

+ type MockVirtualUser struct

+ Data []string

+ func NewMockVU(cfg MockVirtualUserConfig) MockVirtualUser

+ func (m MockVirtualUser) Call(l *Generator)

+ func (m MockVirtualUser) Clone(_ *Generator) VirtualUser

+ func (m MockVirtualUser) Setup(_ *Generator) error

+ func (m MockVirtualUser) Stop(_ *Generator)

+ func (m MockVirtualUser) StopChan() chan struct{}

+ func (m MockVirtualUser) Teardown(_ *Generator) error

+ type MockVirtualUserConfig struct

+ CallSleep time.Duration

+ FailRatio int

+ TimeoutRatio int

type Profile

+ func NewVUProfile(t *testing.T, labels map[string]string, pp []*ProfileVUPart) (*Profile, error)

+ type ProfileVUPart struct

+ Name string

+ Schedule []*Segment

+ VU VirtualUser

type Stats

+ CurrentVUs atomic.Int64

+ type VirtualUser interface

+ Call func(l *Generator)

+ Clone func(l *Generator) VirtualUser

+ Setup func(l *Generator) error

+ Stop func(l *Generator)

+ StopChan func() chan struct{}

+ Teardown func(l *Generator) error

+ type WSMockVU struct

+ Data []string

+ func NewWSMockVU(cfg WSMockVUConfig) WSMockVU

+ func (m WSMockVU) Call(l *Generator)

+ func (m WSMockVU) Clone(_ *Generator) VirtualUser

+ func (m WSMockVU) Setup(l *Generator) error

+ func (m WSMockVU) Stop(_ *Generator)

+ func (m WSMockVU) StopChan() chan struct{}

+ func (m WSMockVU) Teardown(_ *Generator) error

+ type WSMockVUConfig struct

+ TargetURl string

Apr 14, 2023

Changes in this version

+ const AlertTypeErrors

+ const AlertTypeQuantile99

+ const DefaultAlertEvaluateEvery

+ const DefaultAlertFor

+ const DefaultDashboardUUID

+ const DefaultRequirementLabelKey

+ const DefaultStatTextSize

+ const DefaultStatValueSize

+ func LokiAlertParams(queryType, testName, genName string) string

type AlertChecker

+ RequirementLabelKey string

+ type Dashboard struct

+ func NewDashboard() *Dashboard

+ func (m *Dashboard) Dashboard(datasourceName string, requirements []WaspAlert) (dashboard.Builder, error)

+ func (m *Dashboard) Deploy(reqs []WaspAlert) (*grabana.Dashboard, error)

+ type HTTPMockServerConfig struct

+ FirstAPIHTTPCode int

+ FirstAPILatency time.Duration

+ SecondAPIHTTPCode int

+ SecondAPILatency time.Duration

+ type WaspAlert struct

+ AlertIf alert.ConditionEvaluator

+ AlertType string

+ CustomAlert timeseries.Option

+ GenName string

+ Name string

+ RequirementGroupName string

+ TestName string

Apr 13, 2023

Changes in this version

+ const DefaultCallResultBufLen

+ const DefaultCallTimeout

+ const DefaultStatsPollInterval

+ const DefaultStepChangePrecision

+ const InstancesScheduleType

+ const LogLevelEnvVar

+ const RPSScheduleType

+ var ErrCallTimeout = errors.New("generator request call timeout")

+ var ErrInvalidSteps = errors.New("both \"Steps\" and \"StepsDuration\" must be defined in a schedule segment")

+ var ErrNoCfg = errors.New("config is nil")

+ var ErrNoGun = errors.New("rps load scheduleSegments selected but gun implementation is nil")

+ var ErrNoImpl = errors.New("either \"gun\" or \"instanceTemplate\" implementation must provided")

+ var ErrNoInstance = errors.New(...)

+ var ErrNoSched = errors.New("no schedule segments were provided")

+ var ErrStartFrom = errors.New("from must be > 0")

+ var ErrWrongScheduleType = errors.New(...)

+ func GetLogger(t *testing.T, componentName string) zerolog.Logger

+ func InitDefaultLogging()

+ func LabelsMapToModel(m map[string]string) model.LabelSet

+ type Alert struct

+ Annotations struct{ ... }

+ EndsAt time.Time

+ Fingerprint string

+ GeneratorURL string

+ Labels map[string]string

+ Receivers []struct{ ... }

+ StartsAt time.Time

+ Status struct{ ... }

+ UpdatedAt time.Time

+ type AlertChecker struct

+ APIKey string

+ RequirementLabelName string

+ T *testing.T

+ URL string

+ func NewAlertChecker(t *testing.T, requirenemtLabelName string) *AlertChecker

+ func (m *AlertChecker) AnyAlerts(dashboardUUID, requirementLabelValue string) error

+ type AlertGroupsResponse struct

+ Alerts []Alert

+ Labels struct{ ... }

+ Receiver struct{ ... }

+ type CallResult struct

+ Data interface{}

+ Duration time.Duration

+ Error string

+ Failed bool

+ FinishedAt *time.Time

+ StartedAt *time.Time

+ Timeout bool

+ type Config struct

+ CallResultBufLen int

+ CallTimeout time.Duration

+ GenName string

+ Gun Gun

+ Instance Instance

+ Labels map[string]string

+ LoadType string

+ Logger zerolog.Logger

+ LokiConfig *LokiConfig

+ Schedule []*Segment

+ SharedData interface{}

+ StatsPollInterval time.Duration

+ T *testing.T

+ func (lgc *Config) Validate() error

+ type ExtendedLokiClient interface

+ AllHandleResults func() []PromtailSendResult

+ HandleStruct func(ls model.LabelSet, t time.Time, st interface{}) error

+ LastHandleResult func() PromtailSendResult

+ func NewMockPromtailClient() ExtendedLokiClient

+ type Generator struct

+ Log zerolog.Logger

+ ResponsesChan chan CallResult

+ ResponsesCtx context.Context

+ ResponsesWaitGroup *sync.WaitGroup

+ func NewGenerator(cfg *Config) (*Generator, error)

+ func (l *Generator) Errors() []string

+ func (l *Generator) GetData() *ResponseData

+ func (l *Generator) InputSharedData() interface{}

+ func (l *Generator) Run(wait bool) (interface{}, bool)

+ func (l *Generator) Stats() *Stats

+ func (l *Generator) StatsJSON() map[string]interface{}

+ func (l *Generator) Stop() (interface{}, bool)

+ func (l *Generator) Wait() (interface{}, bool)

+ type Gun interface

+ Call func(l *Generator) CallResult

+ type HTTPMockServer struct

+ Sleep time.Duration

+ func NewHTTPMockServer(sleep time.Duration) *HTTPMockServer

+ func (s *HTTPMockServer) Run()

+ func (s *HTTPMockServer) URL() string

+ type Instance interface

+ Clone func(l *Generator) Instance

+ Run func(l *Generator)

+ Stop func(l *Generator)

+ type LocalLogger struct

+ func (m *LocalLogger) Log(kvars ...interface{}) error

+ type LokiClient struct

+ func NewLokiClient(extCfg *LokiConfig) (*LokiClient, error)

+ func (m *LokiClient) AllHandleResults() []PromtailSendResult

+ func (m *LokiClient) Handle(ls model.LabelSet, t time.Time, s string) error

+ func (m *LokiClient) HandleStruct(ls model.LabelSet, t time.Time, st interface{}) error

+ func (m *LokiClient) LastHandleResult() PromtailSendResult

+ func (m *LokiClient) Stop()

+ type LokiConfig struct

+ BatchSize int

+ BatchWait time.Duration

+ Timeout time.Duration

+ Token string

+ URL string

+ func NewDefaultLokiConfig(url string, token string) *LokiConfig

+ func NewEnvLokiConfig() *LokiConfig

+ type MockGun struct

+ Data []string

+ func NewMockGun(cfg *MockGunConfig) *MockGun

+ func (m *MockGun) Call(l *Generator) CallResult

+ type MockGunConfig struct

+ CallSleep time.Duration

+ FailRatio int

+ TimeoutRatio int

+ type MockHTTPGun struct

+ Data []string

+ func NewHTTPMockGun(cfg *MockHTTPGunConfig) *MockHTTPGun

+ func (m *MockHTTPGun) Call(l *Generator) CallResult

+ type MockHTTPGunConfig struct

+ TargetURL string

+ type MockInstance struct

+ Data []string

+ func NewMockInstance(cfg MockInstanceConfig) MockInstance

+ func (m MockInstance) Clone(l *Generator) Instance

+ func (m MockInstance) Run(l *Generator)

+ func (m MockInstance) Stop(l *Generator)

+ type MockInstanceConfig struct

+ CallSleep time.Duration

+ FailRatio int

+ TimeoutRatio int

+ type MockPromtailClient struct

+ OnHandleEntry api.EntryHandlerFunc

+ Results []PromtailSendResult

+ func (c *MockPromtailClient) AllHandleResults() []PromtailSendResult

+ func (c *MockPromtailClient) Handle(labels model.LabelSet, time time.Time, entry string) error

+ func (c *MockPromtailClient) HandleStruct(ls model.LabelSet, t time.Time, st interface{}) error

+ func (c *MockPromtailClient) LastHandleResult() PromtailSendResult

+ func (c *MockPromtailClient) Stop()

+ type MockWSServer struct

+ Logf func(f string, v ...interface{})

+ Sleep time.Duration

+ func (s MockWSServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Profile struct

+ Generators []*Generator

+ func NewInstanceProfile(t *testing.T, labels map[string]string, pp []*ProfileInstancePart) (*Profile, error)

+ func NewRPSProfile(t *testing.T, labels map[string]string, pp []*ProfileGunPart) (*Profile, error)

+ func (m *Profile) Run(wait bool) error

+ func (m *Profile) Wait()

+ type ProfileGunPart struct

+ Gun Gun

+ Name string

+ Schedule []*Segment

+ type ProfileInstancePart struct

+ Instance Instance

+ Name string

+ Schedule []*Segment

+ type PromtailSendResult struct

+ Entry string

+ Labels model.LabelSet

+ Time time.Time

+ type ResponseData struct

+ FailResponses *SliceBuffer[CallResult]

+ OKData *SliceBuffer[any]

+ OKResponses *SliceBuffer[CallResult]

+ type Segment struct

+ From int64

+ Increase int64

+ StepDuration time.Duration

+ Steps int64

+ func Combine(segs ...[]*Segment) []*Segment

+ func CombineAndRepeat(times int, segs ...[]*Segment) []*Segment

+ func Line(from, to int64, duration time.Duration) []*Segment

+ func Plain(from int64, duration time.Duration) []*Segment

+ func (ls *Segment) Validate(cfg *Config) error

+ type SliceBuffer struct

+ Capacity int

+ Data []T

+ Idx int

+ func NewSliceBuffer(cap int) *SliceBuffer[T]

+ func (m *SliceBuffer[T]) Append(s T)

+ type Stats struct

+ CallTimeout atomic.Int64

+ CurrentInstances atomic.Int64

+ CurrentRPS atomic.Int64

+ CurrentSegment atomic.Int64

+ CurrentStep atomic.Int64

+ Failed atomic.Int64

+ LastSegment atomic.Int64

+ RunFailed atomic.Bool

+ RunStopped atomic.Bool

+ Success atomic.Int64

+ type WSMockConfig struct

+ TargetURl string

+ type WSMockInstance struct

+ Data []string

+ func NewWSMockInstance(cfg WSMockConfig) WSMockInstance

+ func (m WSMockInstance) Clone(l *Generator) Instance

+ func (m WSMockInstance) Run(l *Generator)

+ func (m WSMockInstance) Stop(l *Generator)